Flink Table对接Kafka Connector窗口聚合无结果问题咨询
Flink TUMBLE窗口聚合无结果问题
我通过以下SQL创建了Bid表:
create table Bid( auction BIGINT, bidder BIGINT, price BIGINT, channel VARCHAR, url VARCHAR, dateTime TIMESTAMP(3), extra VARCHAR, `record_time` TIMESTAMP_LTZ(3) METADATA FROM 'tenter image description hereimestamp' , WATERMARK FOR dateTime AS dateTime - INTERVAL '4' SECOND) with ( 'connector' = 'kafka', 'topic' = 'test', 'properties.bootstrap.servers' = 'localhost:9092', 'properties.group.id' = 'testGroup', 'scan.startup.mode' = 'latest-offset', 'format' = 'csv' );
执行基于TUMBLE窗口的聚合查询时,无论运行数据生成器多久,均无结果返回:
SELECT window_start, window_end, COUNT(*) FROM TABLE( TUMBLE(TABLE Bid, DESCRIPTOR(dateTime), INTERVAL '1' SECOND) ) GROUP BY window_start, window_end;
但我确认数据落在窗口内——执行以下非聚合查询能得到结果,结果显示每条数据都对应了正确的window_start和window_end:
select `record_time`,window_start, window_end FROM TABLE(TUMBLE(TABLE Bid, DESCRIPTOR(dateTime), INTERVAL '1' SECOND));
同时Flink Web监控也显示已有记录成功接收。
内容的提问来源于stack exchange,提问作者lanny
相关产品推荐
相关产品推荐

