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

FlinkFlink SQL 读取 CSV 文件

FlinkFlink 部分算子是 FinishSHED 不做checnpoint

FlinkFlink 模拟 kafka 消费重启后 能接着读取 保存状态信息