Hi，刘小红： 这个我查阅过，实验过，通过idle source 是无法解决的。 可以查看这个链接：http://apache-flink.147419.n8.nabble.com/Flink-SQL-td4535.html
在我的这个场景里面，上游已经配置了idle source，上游如果突然没有数据了，下游的flink 窗口还是无法关闭输出结果。 这个说明idle source 无法解决这个问题 刘小红 <[email protected]> 于2021年1月28日周四 下午3:01写道： > 可以调用WatermarkStrategy.withIdleness(Duration idleTimeout) > 指定空闲超时时间，这样不会影响水印的进度，进而影响下游算子操作 > > > | | > 刘小红 > | > | > [email protected] > | > 签名由网易邮箱大师定制 > 在2021年1月28日 14:42，wpp<[email protected]> 写道： > 可以按照proceeTime来处理吧 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
