为什么flink 1.15.2显示No Watermark(水印仅在使用EventTime时可用)

oxcyiej7 于 2023-04-10 发布在 Apache

关注(0)|答案(1)|浏览(660)

在我的创建表ddl中，我在列上设置了水印，并在1分钟的滚动窗口上做了简单的计数（不同的userId），但仍然没有得到任何数据，同样的简单工作在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'
          );

另外，我们有其他作业迁移，但没有数据与输出匹配。是否有任何水印默认设置，我们需要设置。