如何在Confluent Flink窗口查询中使用SQL Hints？

在Confluent Flink的SQL窗口查询中，Hints需要直接作用于对应的源表，也就是把Hint语句放在你要配置的表引用之前。针对你提供的查询语句，正确的用法是将指定Hint加在源表topic1的TABLE声明前。

整合后的完整查询语句 #

INSERT INTO topic2(id, name, avgValue)
SELECT id, name, AVG(value) as avgValue
FROM TABLE(TUMBLE(TABLE /*+ OPTIONS('scan.startup.mode'='latest-offset') */ topic1, DESCRIPTOR(messageTimestamp), INTERVAL '30' SECONDS))
GROUP BY window_start, window_end, id, name;

关键说明 #

• Hint的作用对象是topic1这个Kafka源表，必须紧邻在TABLE关键字和表名topic1之间，这样Flink才能识别到该Hint是对这个源表的配置。
• 这个Hint会指定Kafka源的启动消费模式为latest-offset，即从最新的偏移量开始消费数据，适合不需要回溯历史数据的场景。

内容的提问来源于stack exchange，提问作者Houston