Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator

[zhangsir1993]

msyql一张表的PRIMARY KEY 类型为bigint ， 长度是这种：1318118613838070748
直接Job failed during initialization of JobManager
然后yarn session 也跟着挂了 应该是内存爆了吧

请问：是否有这样的bug?

[leonardBang]

hi，这里贴下详细异常，只从Job failed during initialization of JobManager 无法推断呢

[zhangsir1993]

应该不是PRIMARY KEY 长度导致的问题，唯独这张表会报错。。。直接导致集群挂掉
2021-09-09 06:59:56,244 ERROR org.apache.flink.runtime.util.FatalExitExceptionHandler [] - FATAL: Thread 'SourceCoordinator-Source: TableSourceScan(table=[[default_catalog, default_database, callcenter_callrecords]], fields=[id, customer_id, customer_no])' 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: TableSourceScan(table=[[default_catalog, default_database, callcenter_callrecords]], fields=[id, customer_id, customer_no]),5,main]
at org.apache.flink.runtime.source.coordinator.SourceCoordinatorProvider$CoordinatorExecutorThreadFactory.newThread(SourceCoordinatorProvider.java:119) [flink-dist_2.11-1.13.2.jar:1.13.2]
at java.util.concurrent.ThreadPoolExecutor$Worker.(ThreadPoolExecutor.java:619) ~[?:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:932) ~[?:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor.processWorkerExit(ThreadPoolExecutor.java:1025) ~[?:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1167) ~[?:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_181]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
2021-09-09 06:59:56,250 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Shutting YarnSessionClusterEntrypoint down with application status UNKNOWN. Diagnostics Cluster entrypoint has been closed externally..