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

【flink】flink Source Coordinator Thread already exists driving actions Source Coordinator. Existing相关推荐

【FLink】Flink 消费 kafka 消费组死掉 Marking the coordinator dead for group 造成数据重复消费
文章目录 1.概述 2.源码分析 2.2 能不能设置多次提交呢? 2.3 监控日志 1.概述首先参考几个案例: [Flink]Flink Kafka 消费卡死消费组卡死 topic无写入实际有数 ...
【Flink】Flink 源码阅读笔记（20）- Flink 基于 Mailbox 的线程模型
1.概述转载:Flink 源码阅读笔记(20)- Flink 基于 Mailbox 的线程模型相似文章:[Flink]Flink 基于 MailBox 实现的 StreamTask 线程模型 Fl ...
【Flink】Flink 部分算子是 FinishSHED 不做checnpoint
文章目录 1.概述 1.概述转载:记一次flink不做checkpoint的问题请参考原文,这里仅仅是学习一下. 问题现象: Flink UI界面查看checkpoint的metrics发现一直没 ...
【flink】Flink常见Checkpoint超时问题排查思路
1.概述转载:Flink常见Checkpoint超时问题排查思路这里仅仅是自己学习. 在日常flink应用中,相信大家经常会遇到checkpoint超时失败这类的问题,遇到这种情况的时候仅仅只会在 ...
【Flink】Flink 控制台能消费但是 Flink 任务不能消费内置topic 导致问题
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 文章目录 1.概述 2.场景2 1.概述一个流任务,在其他环境都正常,但是有个环境突然不正常了,数据消 ...
【flink】Flink 1.12.2 源码浅析 : yarn-per-job模式解析 JobMasger启动 YarnJobClusterEntrypoint
1.概述转载:Flink 1.12.2 源码浅析 : yarn-per-job模式解析 [三] 上一章:[flink]Flink 1.12.2 源码浅析 : yarn-per-job模式解析 yar ...
【Flink】flink并行度与kafka分区(partition)设置
1.概述默认: [Flink]FlinkConsumer是如何保证一个partition对应一个thread的当分区与并行度不一样呢? 2.原理采用取模运算:平衡 kafka partition ...
【3】flink sink
[README] 本文记录了flink sink操作,输出目的存储器(中间件)包括 kafka: es: db: 等等有很多: 本文只给出了 sink2kafka的代码: 本文使用的flink为 1. ...
【2】flink数据流转换算子
[README] 本文记录了flink对数据的转换操作,包括基本转换,map,flatMap,filter: 滚动聚合(min minBy max maxBy sum): 规约聚合-reduce: ...

【flink】flink Source Coordinator Thread already exists driving actions Source Coordinator. Existing

文章目录

1.概述

【flink】flink Source Coordinator Thread already exists driving actions Source Coordinator. Existing相关推荐

最新文章

热门文章