目录背景Yarn 上面查看日志背景FLink on yarn Cluster 模式运行一段时间后，程序突然报错，查找Exceotion 发现 ”Container released on a *lost* node”具体报错如下。2021-12-24 09:43:43,931 INFOorg.apache.flink.runtime.executiongraph.ExecutionGraph- F

对于这个异常，要具体问题具体分析，我这个异常是因为在使用侧输出流的时候， outputTag<String>, 向kafka发送数据的时候序列化用的是JSONOBJECT， String cant be cast ....jsonobject 导致的。18:37:53,728 WARNorg.apache.flink.streaming.api.operators.AbstractSt

The application contains no execute() calls.没有调用 execute() 方法。2021-12-03 09:20:31 [flink-akka.actor.default-dispatcher-4] WARNApplicationDispatcherBootstrap:169 - Application failed unexpectedly:java.