You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Flink Table对接Kafka Connector窗口聚合无结果问题咨询

我通过以下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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.20 17:56:05