1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
Idea中執(zhí)行任務(wù)時，沒法看到JobManager的錯誤，以至于我以為是什么特殊的原因?qū)е氯蝿?wù)總是反復(fù)消費。在close方法中，增加日志，發(fā)現(xiàn)jdbc連接被關(guān)閉了。 重新消費，jdbc連接又啟動了。

注意，在Flink的函數(shù)中，open和close方法只在任務(wù)啟動和結(jié)束的時候執(zhí)行一次。反之，可以推理出，如果close方法被執(zhí)行了，那么說明任務(wù)掛了。
在本地任務(wù)中增加本地Flink UI，很明顯可以看到任務(wù)在不斷的重啟。JobManager中有明顯的Exception，就是

SQLSyntaxErrorException: Unknown column 'day_after_back' in 'field list'