Flink SQL Join 如何使用minBatch 方式查询

Mon, 08 Nov 2021 01:45:24 -0800 

Hi :
   我现在有一个场景，基于Flink 1.12 SQL 来实现， 想查询下游数据， 大概逻辑就是多张表Join 其中一张是Kafka 表，其他的是DB 
表，我基于处理时间 FOR SYSTEM_TIME AS 做了Temporal Joins ， 但是下游数据库查询压力比较大， 现在想通过延迟 批量 In 
的方式 减小QPS ，请问如何配置 可以调这个时间长度，我理解默认就是来一条就查询一次



---
Best,
WuKong

回复