Kafka/Flink: Fix DDL statement

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

Kafka/Flink: Fix DDL statement #509

Closed wierdvanderhaar closed 3 months ago

wierdvanderhaar commented 3 months ago

Summary of the changes / Why this is an improvement

docker-compose is a separate executable nowadays.
The ingest from Flink fails when you use the old create table statement because only location and current are ingested. With these generated columns, we are sure that the ingests are successful.

Checklist

[ ] Link to issue this PR refers to (if applicable):
[ ] CLA is signed

amotl commented 3 months ago

Hi. Thanks for your fix. For the sake of clarity, please use a better commit message, for example like Kafka/Flink: Fix DDL statement.