Flink任務失敗，其實是個小問題，但是看不到真正的日誌誤導，你都不會發現是哪裡除了問題，直到你懷疑自己。

由於通過跳轉機登入的一個伺服器，然後無法檢視Flink執行的task日誌，只有在flink目錄下的log，但是這個log只有部分日誌，程式碼輸出日誌級別不夠也是看不到，而且還是通過flink-per-job的方式提交的。

解決：

切換到yarn-session方式，這樣就算是跳轉機的那個，只要能訪問的那個IP上可以看到flink的執行日誌就可以確定異常問題是什麼原因造成的，最後是資料來源硬編碼改了，hbase表的結構也變了，但是在flinkUI的日誌裡都可以看到這些資訊。

總結：

如果程式碼出現未知的異常，就找日誌，日誌不全就得想辦法找到更詳細的日誌，只有打印出了所有的詳細日誌才能處理。有時候列印的日誌只是部分日誌，按邏輯來，不急，so easy