Tony Wang
02/16/2023, 11:45 PMFlink 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.