File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -20,7 +20,7 @@ CREATE TEMPORARY TABLE currency_rates (
20
20
` currency_code` STRING,
21
21
` eur_rate` DECIMAL (6 ,4 ),
22
22
` rate_time` TIMESTAMP (3 ),
23
- WATERMARK FOR ` rate_time` AS rate_time - INTERVAL ' 15' SECONDS ,
23
+ WATERMARK FOR ` rate_time` AS rate_time - INTERVAL ' 15' SECOND ,
24
24
PRIMARY KEY (currency_code) NOT ENFORCED
25
25
) WITH (
26
26
' connector' = ' upsert-kafka' ,
@@ -35,7 +35,7 @@ CREATE TEMPORARY TABLE transactions (
35
35
` currency_code` STRING,
36
36
` total` DECIMAL (10 ,2 ),
37
37
` transaction_time` TIMESTAMP (3 ),
38
- WATERMARK FOR ` transaction_time` AS transaction_time - INTERVAL ' 30' SECONDS
38
+ WATERMARK FOR ` transaction_time` AS transaction_time - INTERVAL ' 30' SECOND
39
39
) WITH (
40
40
' connector' = ' kafka' ,
41
41
' topic' = ' transactions' ,
You can’t perform that action at this time.
0 commit comments