取消
顯示的結果
而不是尋找
你的意思是:

試著捕捉多個流寫在工作

AdamRink
新的貢獻者三世

我們有問題檢查站和模式版本的日期(不知道為什麼),但它會導致工作失敗。我們有工作運行15 - 30流查詢,所以如果一個失敗,產生了一個問題。我想使檢查點錯誤,重新設置檢查點和日誌失敗。不是最優,因為我再處理流或者至少我們看的窗口。

所以我的問題就是似乎錯誤陷阱流的唯一方法是使用awaitTermination ()……這個鎖筆記本和下一個流才開始第一個流是終止。awaitAnyTermination()不會趕上工作開始時,出現錯誤,因為之前的工作停止awaitAnyTermination嗎?

5回複5

推特)嗨@溜冰場,

隻是一個友好的後續。你還需要幫助或@Kaniz Fatma響應幫助解決你的問題嗎?

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map