WangMinChao created FLINK-24855:
-----------------------------------
Summary: Source Coordinator Thread already exists. There should
never be more than one thread driving the actions of a Source Coordinator.
Key: FLINK-24855
URL: https://issues.apache.org/jira/browse/FLINK-24855
Project: Flink
Issue Type: Bug
Components: API / Core, Runtime / Coordination
Affects Versions: 1.13.3
Environment: flink 1.13.3
flink-cdc 2.1
Reporter: WangMinChao
When I am synchronizing large tables, have the following problems :
2021-11-09 20:33:04,222 INFO
com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] -
Assign split MySqlSnapshotSplit\{tableId=db.table, splitId='db.table:383',
splitKeyType=[`id` BIGINT NOT NULL], splitStart=[9798290], splitEnd=[9823873],
highWatermark=null} to subtask 1
2021-11-09 20:33:04,248 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 101 (type=CHECKPOINT) @ 1636461183945 for job
3cee105643cfee78b80cd0a41143b5c1.
2021-11-09 20:33:10,734 ERROR
org.apache.flink.runtime.util.FatalExitExceptionHandler [] - FATAL: Thread
'SourceCoordinator-Source: mysqlcdc-source -> Sink: kafka-sink' produced an
uncaught exception. Stopping the process...
java.lang.Error: Source Coordinator Thread already exists. There should never
be more than one thread driving the actions of a Source Coordinator. Existing
Thread: Thread[SourceCoordinator-Source: mysqlcdc-source -> Sink:
kafka-sink,5,main]
at
org.apache.flink.runtime.source.coordinator.SourceCoordinatorProvider$CoordinatorExecutorThreadFactory.newThread(SourceCoordinatorProvider.java:119)
[flink-dist_2.12-1.13.3.jar:1.13.3]
at
java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:619)
~[?:1.8.0_191]
at
java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932)
~[?:1.8.0_191]
at
java.util.concurrent.ThreadPoolExecutor.processWorkerExit(ThreadPoolExecutor.java:1025)
~[?:1.8.0_191]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1167)
~[?:1.8.0_191]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_191]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
