做好我局门户网站建设工作,郑州修了你官方网站,微信问卷调查小程序怎么做,一级a做爰网站下载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中执行任务时#xff0c;没法看到JobManager的错误#xff0c;以至于我以为是什么特殊的原因导致任务总是反复消费。在close方法中#xff0c;增加日志#xff0c;发现jdbc连接被关闭了。 重新… 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中执行任务时没法看到JobManager的错误以至于我以为是什么特殊的原因导致任务总是反复消费。在close方法中增加日志发现jdbc连接被关闭了。 重新消费jdbc连接又启动了。
注意在Flink的函数中open和close方法只在任务启动和结束的时候执行一次。反之可以推理出如果close方法被执行了那么说明任务挂了。 在本地任务中增加本地Flink UI很明显可以看到任务在不断的重启。JobManager中有明显的Exception就是
SQLSyntaxErrorException: Unknown column day_after_back in field list
