Kafka/Flink: Fix DDL statement (#509)

Changed-Wierd
crate · Jul 3, 2024 · 17f277c · 17f277c
1 parent e5d9c34
commit 17f277c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/application/apache-kafka-flink-streaming/README.md b/application/apache-kafka-flink-streaming/README.md
@@ -40,7 +40,7 @@ into your local `.env` file.
 ### Run the docker compose (and build the images)
 
 ```
-docker compose up -d --build
+docker-compose up -d --build
 ```
 
 ### Stop the docker compose
@@ -111,7 +111,7 @@ Create the table in CrateDB:
 
 ```sql
 CREATE TABLE IF NOT EXISTS "doc"."weather_flink_sink" (
-  "inserted_at" TIMESTAMP WITHOUT TIME ZONE NOT NULL,
+  "inserted_at" TIMESTAMP WITH TIME ZONE NOT NULL GENERATED ALWAYS AS now(),
   "location" OBJECT(DYNAMIC),
   "current" OBJECT(DYNAMIC)
 )