Flink SQL中可撤回機制解密

點擊上方藍sql 字關注~c#         場景案例 先從一個實際業務場景理解Flink SQL中的撤回機制：設備狀態上線/下線數量統計，上游採集設備狀態發送到Kafka中，最開始是一個上線狀態，此時統計到上線數量+1，過了一段時間該設備下線了，收到的下線的狀態，那麼此時應該是上線數量-1，下線數量+1，如今須要實現這樣一個需求，看一下在Flink SQL裏面如何實現api

>>阅读原文<<