长沙企业网站建设公,h5页面制作软件thinkphp,有没有像一起做网店做男装的网站,内网门户网站建设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