Watermarks in batch mode: if I turn on minibatch p...
# troubleshooting
t
Watermarks in batch mode: if I turn on minibatch processing like this:
Copy code
Flink SQL> SET 'table.exec.mini-batch.enabled' = 'true';
Flink SQL> SET 'table.exec.mini-batch.allow-latency' = '5s';
Flink SQL> SET 'table.exec.mini-batch.size' = '5000';
Does watermarks set like this:
create TABLE users_table (ts TIMESTAMP(3), user_id INT, category INT, price FLOAT, featureA INT, WATERMARK FOR ts AS ts) WITH ('connector'='filesystem','path'='/home/ziheng/streaming-stuff/datagen/users.csv','format'='csv');
even work? When I printed out that table it showed a watermark column but that watermark is based on the processing time on my computer instead of the
ts
column defined.
➕ 1