Flink的operator chain引起的問題

今天早上在羣裏有人問了這樣一個問題,我當時只看了截圖沒看他的代碼,而後我倆在那聊了半天,最後發現不在一個頻道,後面我仔細看了一下,他的代碼明白了他的邏輯,我先簡單描述一下場景,他在Flink流開始的時候直接把原數據分別sink到了es和gp庫,而後把處理過的流拿了兩個測流輸出,最後分別把這兩個測流sink到了es和gp,至關於他一共有4個sink,可是他在Flink的UI上面看到的DAG圖是這樣的

>>阅读原文<<