分组滚动窗口 无法触发计算，由于 watermark 没有被生成，或者被计算。

Sun, 11 Apr 2021 10:50:03 -0700 

大家好，我有一个 Flink 程序， 使用事件时间做分组窗口计算，但是无法触发窗口计算。我Debug到 WindowOperator,  下，
发现 WindowOperator 的 TriggerContext中的当前水印一直是一个负数， StreamTaskNetworkInput 中的
processElement 方法没有接受到 watermark 消息， recordOrMark.isWatermark() == false。

我自己的怀疑难道是事件时间每设置对? 但是对比了文档，应该是可以的。下面是我的 DDL

create table input_table (
`dim` varchar,
 `server_time` bigint,
 `event_time` AS TO_TIMESTAMP(FROM_UNIXTIME(server_time / 1000, 'yyyy-MM-dd
HH:mm:ss')),
 WATERMARK FOR `event_time` AS `event_time`
)
select TUMBLE_START(`event_time`, INTERVAL '1' SECOND) AS `log_time`,
`dim`,
count(1),
FROM input_table
 GROUP BY TUMBLE(`event_time`, INTERVAL '1' SECOND),`dim`



*Best Regards*
*Jeremy Mei*

回复