回复： kafka 所有分区无数据的情况下，导致watermark无法前进

Wed, 27 Jan 2021 23:01:34 -0800 

可以调用WatermarkStrategy.withIdleness(Duration idleTimeout) 
指定空闲超时时间，这样不会影响水印的进度，进而影响下游算子操作


| |
刘小红
|
|
[email protected]
|
签名由网易邮箱大师定制
在2021年1月28日 14:42，wpp<[email protected]> 写道：
可以按照proceeTime来处理吧



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复