Google Dataflow：設置DefaultUncaughtExceptionHandler

Question

是否可以爲Dataflow中的每個工作者和線程設置DefaultUncaughtExceptionHandler？

類似於Thread.setDefaultUncaughtExceptionHandler。

Answer 1

不，我不這麼認爲。用於表達用戶代碼的數據流模型在比個別工作者和線程更高的抽象層次上運行。你能否擴展一下你爲什麼想在全球範圍內做到這一點？

數據流服務已經重試了用戶代碼中的所有未捕獲的異常。元素被稱爲bundle的組被處理 - 如果bundle中的任何元素導致異常被拋出，那麼整個bundle將被重試。在批處理模式下，重試失敗的捆綁包，直到單個捆綁包失敗4次，此時作業失敗。在流模式下，儘管您可以使用update功能來更新代碼以更好地處理問題，但無限期重試綁定失敗。

所有這些異常都將出現在Dataflow UI和Cloud Logging工作日誌中的作業日誌中。查看更多信息here。