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

[刘小红 <18...@163.com>]

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


| |
刘小红
|
|
18500348251@163.com
|
签名由网易邮箱大师定制
在2021年1月28日 14:42，wpp<12...@qq.com> 写道：
可以按照proceeTime来处理吧



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

Re: kafka 所有分区无数据的情况下，导致watermark无法前进

[林影 <br...@gmail.com>]

Hi，刘小红：
这个我查阅过，实验过，通过idle source 是无法解决的。
可以查看这个链接：http://apache-flink.147419.n8.nabble.com/Flink-SQL-td4535.html

在我的这个场景里面，上游已经配置了idle source，上游如果突然没有数据了，下游的flink 窗口还是无法关闭输出结果。
这个说明idle source 无法解决这个问题

刘小红 <18...@163.com> 于2021年1月28日周四 下午3:01写道：

> 可以调用WatermarkStrategy.withIdleness(Duration idleTimeout)
> 指定空闲超时时间，这样不会影响水印的进度，进而影响下游算子操作
>
>
> | |
> 刘小红
> |
> |
> 18500348251@163.com
> |
> 签名由网易邮箱大师定制
> 在2021年1月28日 14:42，wpp<12...@qq.com> 写道：
> 可以按照proceeTime来处理吧
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>