flinkflink Source Coordinator Thread already exists driving actions Source Coordinator. Existing
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了flinkflink Source Coordinator Thread already exists driving actions Source Coordinator. Existing相关的知识,希望对你有一定的参考价值。
文章目录
1.概述
一个flink程序,什么也没做 ,昨天晚上9点的时候 集群突然就挂了,我7点下班的时候 还好好的
然后报错:Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator. Existing Thread
具体异常栈如下
报错位置位于:org.apache.flink.runtime.source.coordinator.SourceCoordinatorProvider.CoordinatorExecutorThreadFactory#newThread
以上是关于flinkflink Source Coordinator Thread already exists driving actions Source Coordinator. Existing的主要内容,如果未能解决你的问题,请参考以下文章
flinkflink Source Coordinator Thread already exists driving actions Source Coordinator. Existing
FlinkFlink SQL 自定义 Source format
FlinkFlink flink-runtime.version.properties generated correctly. You MUST run mvn generate-source