02-14-202203:03點
我們有問題檢查站和模式版本的日期(不知道為什麼),但它會導致工作失敗。我們有工作運行15 - 30流查詢,所以如果一個失敗,產生了一個問題。我想使檢查點錯誤,重新設置檢查點和日誌失敗。不是最優,因為我再處理流或者至少我們看的窗口。
所以我的問題就是似乎錯誤陷阱流的唯一方法是使用awaitTermination ()……這個鎖筆記本和下一個流才開始第一個流是終止。awaitAnyTermination()不會趕上工作開始時,出現錯誤,因為之前的工作停止awaitAnyTermination嗎?
04-05-2022下午03:36
推特)嗨@溜冰場,
隻是一個友好的後續。你還需要幫助或@Kaniz Fatma響應幫助解決你的問題嗎?
從未顯出
加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。
點擊在這裏注冊今天,加入!
參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。