Flink window ReduceFunction 在一個事件到來的時候被觸發屢次

今天有一個同窗在羣裏面問了以下一個問題：java 「每輸入條記錄，都會當即執行四次。。」 session ------less 由於一直都是用的event time + watermark的方式來作的流，不太清楚他這個狀況。一度覺得是事件被複制了多份，致使了窗口Function被觸發屢次。ide 後來看了一下源碼，發現這個問題其實很簡單。reduce function跟普通的function不同，

>>阅读原文<<