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ù)時(shí)，沒(méi)法看到JobManager的錯(cuò)誤，以至于我以為是什么特殊的原因?qū)е氯蝿?wù)總是反復(fù)消費(fèi)。在close方法中，增加日志，發(fā)現(xiàn)jdbc連接被關(guān)閉了。 重新消費(fèi)，jdbc連接又啟動(dòng)了。

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

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