溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》
您好，登錄后才能下訂單哦！
這篇文章主要為大家展示了“Flink Watermark在任務(wù)之間如何進行傳遞”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“Flink Watermark在任務(wù)之間如何進行傳遞”這篇文章吧。
watermark本質(zhì)上就是數(shù)據(jù)流中根據(jù)記錄中的時間戳生成的一種特殊數(shù)據(jù)，是單調(diào)遞增的。在上下游中的傳遞過程如下：
對于上游中的每個并行子任務(wù)，每個并行度中的watermark都會以廣播的形式發(fā)送給下游的所有并行度。注意watermark作為一種特殊的記錄，是沒有key的，只能廣播給下游所有子任務(wù)。
下游接收到上游所有子任務(wù)發(fā)送過來的watermark后，選擇最小的作為本并行任務(wù)的watermark，并將其廣播給下游。
以上是“Flink Watermark在任務(wù)之間如何進行傳遞”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！
免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權(quán)內(nèi)容。
億速云公眾號
手機網(wǎng)站二維碼
