Skip to content

Commit 17f277c

Browse files
Kafka/Flink: Fix DDL statement (#509)
Changed-Wierd
1 parent e5d9c34 commit 17f277c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

application/apache-kafka-flink-streaming/README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ into your local `.env` file.
4040
### Run the docker compose (and build the images)
4141

4242
```
43-
docker compose up -d --build
43+
docker-compose up -d --build
4444
```
4545

4646
### Stop the docker compose
@@ -111,7 +111,7 @@ Create the table in CrateDB:
111111

112112
```sql
113113
CREATE TABLE IF NOT EXISTS "doc"."weather_flink_sink" (
114-
"inserted_at" TIMESTAMP WITHOUT TIME ZONE NOT NULL,
114+
"inserted_at" TIMESTAMP WITH TIME ZONE NOT NULL GENERATED ALWAYS AS now(),
115115
"location" OBJECT(DYNAMIC),
116116
"current" OBJECT(DYNAMIC)
117117
)

0 commit comments

Comments
 (0)