search

crate / cratedb-examples

A collection of clear and concise examples how to work with CrateDB.
Apache License 2.0
9 stars 7 forks source link

apache-kafka-flink-streaming issues #508

Closed wierdvanderhaar closed 2 months ago

wierdvanderhaar commented 3 months ago

application/apache-kafka-flink-streaming

The create table in the code is not correct, as Flink is ingesting Location and Condition and not inserted_at.

So either the create table should be changed to:

CREATE TABLE IF NOT EXISTS "doc"."weather_flink_sink" (
  "location" OBJECT(DYNAMIC),
  "current" OBJECT(DYNAMIC)
)

Or like we change inserted_at into a generated column.

CREATE TABLE IF NOT EXISTS "doc"."weather_flink_sink" (
  "inserted_at" TIMESTAMP WITHOUT TIME ZONE NOT NULL GENERATED ALWAYS AS now(),
  "location" OBJECT(DYNAMIC),
  "current" OBJECT(DYNAMIC)
);
amotl commented 3 months ago

Hi, and thanks for the report. Can you submit a corresponding adjustment, or can you do it, @surister?

amotl commented 2 months ago

Hi. I think this has been fixed with GH-509, right? Thanks!