Flink window ReduceFunction 在一个事件到来的时候被触发屡次

今天有一个同窗在群里面问了以下一个问题：java “每输入条记录，都会当即执行四次。。” session ------less 由于一直都是用的event time + watermark的方式来作的流，不太清楚他这个状况。一度觉得是事件被复制了多份，致使了窗口Function被触发屡次。ide 后来看了一下源码，发现这个问题其实很简单。reduce function跟普通的function不同，

>>阅读原文<<