異常被拋出（不被catch）會導致flink任務掛掉

背景： 實時效果數據中map的每條數據處理都需要一個單例的對象，這個單例對象的初始化在open方法中 在map每次計算前都會判斷此單例對象是否存在，如果不存在希望flink任務掛掉   思路： 如果發現對象爲null，拋出異常，不catch 空指針異常是運行時異常的子集，拋出哪個都可以，只是空指針異常語義更明確   代碼如下   線上測試 線上部署之後，在task日誌，jobManager日誌，E

>>阅读原文<<