Why flink 1.15.2 showing No Watermark (Watermarks are only available if EventTime is used)

Viewed 11

In my create table ddl, i have set watermark on column and doing simple count(distinct userId) on a tumble window of 1 min, but stil not getting any data, same simple job is working fine in 1.13

CREATE TABLE  test (
                                                        eventName String,
                                                        ingestion_time BIGINT,
                                                        time_ltz AS TO_TIMESTAMP_LTZ(ingestion_time, 3),
    props ROW(userId VARCHAR, id VARCHAR, tourName VARCHAR, advertiserId VARCHAR, deviceId VARCHAR, tourId VARCHAR),
    WATERMARK FOR time_ltz AS time_ltz - INTERVAL '5' SECOND
    ) WITH (
          'connector' = 'kafka',
          'topic' = 'test',
          'scan.startup.mode' = 'latest-offset',
          'properties.bootstrap.servers' = 'localhost:9092',
          'properties.group.id' = 'local_test_flink_115',
          'format' = 'json',
          'json.ignore-parse-errors' = 'true',
          'scan.topic-partition-discovery.interval' = '60000'
          );

Also we have other jobs migrated but no data is matching with output. Is there any watermark default setting we need to set.

enter image description here

0 Answers
Related