2022-06-30 17:49:48,918 WARN io.debezium.relational.history.DatabaseHistoryMetrics [] - Unable to register the MBean 'debezium.mysql:type=connector-metrics,context=schema-history,server=mysql_binlog_source': debezium.mysql:type=connector-metrics,context=schema-history,server=mysql_binlog_source 2022-06-30 17:49:48,919 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - The enumerator receives finished split offsets FinishedSnapshotSplitsReportEvent{finishedOffsets={db_enterprise_3.t_report_detail_2019_0:0={ts_sec=0, file=mysql-bin.000605, pos=193304834, gtids=, row=0, event=0}}} from subtask 0. 2022-06-30 17:49:48,922 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - Assign split MySqlSnapshotSplit{tableId=db_enterprise_3.t_report_detail_2019_0, splitId='db_enterprise_3.t_report_detail_2019_0:1', splitKeyType=[eid
CHAR(36) NOT NULL], splitStart=[0644cd5c-99f6-4d32-aada-248f8beebf03], splitEnd=[0c66cf67-2f7e-4511-b3c9-b9eeaa65cd03], highWatermark=null} to subtask 0 2022-06-30 17:49:49,992 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - The enumerator receives finished split offsets FinishedSnapshotSplitsReportEvent{finishedOffsets={db_enterprise_14.t_report_detail_2017_2:11={ts_sec=0, file=mysql-bin.000893, pos=838226505, gtids=, row=0, event=0}}} from subtask 0. 2022-06-30 17:49:49,998 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - Assign split MySqlSnapshotSplit{tableId=db_enterprise_14.t_report_detail_2017_2, splitId='db_enterprise_14.t_report_detail_2017_2:12', splitKeyType=[eid
CHAR(36) NOT NULL], splitStart=[50865ac7-db4a-42f3-909e-fe3e0933c42e], splitEnd=[573539c0-2694-4e4c-86c7-07094cb1fc2e], highWatermark=null} to subtask 0 2022-06-30 17:49:50,268 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - The enumerator receives finished split offsets FinishedSnapshotSplitsReportEvent{finishedOffsets={db_enterprise_8.t_report_detail_2016_4:26={ts_sec=0, file=mysql-bin.000382, pos=232441216, gtids=, row=0, event=0}}} from subtask 0. 2022-06-30 17:49:50,274 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - Assign split MySqlSnapshotSplit{tableId=db_enterprise_8.t_report_detail_2016_4, splitId='db_enterprise_8.t_report_detail_2016_4:27', splitKeyType=[eid
CHAR(36) NOT NULL], splitStart=[dcc482e5-405a-4b3d-b859-560e04f9be48], splitEnd=[e4f5b639-cdd4-466a-bc2a-092ad6a84348], highWatermark=null} to subtask 0 2022-06-30 17:49:52,347 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - The enumerator receives finished split offsets FinishedSnapshotSplitsReportEvent{finishedOffsets={db_enterprise_14.t_report_detail_2017_2:12={ts_sec=0, file=mysql-bin.000893, pos=838226505, gtids=, row=0, event=0}}} from subtask 0. 2022-06-30 17:49:52,352 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - Assign split MySqlSnapshotSplit{tableId=db_enterprise_14.t_report_detail_2017_2, splitId='db_enterprise_14.t_report_detail_2017_2:13', splitKeyType=[eid
CHAR(36) NOT NULL], splitStart=[573539c0-2694-4e4c-86c7-07094cb1fc2e], splitEnd=[5ddee72f-55a8-417c-8f36-851756ab882e], highWatermark=null} to subtask 0 2022-06-30 17:49:52,687 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - The enumerator receives finished split offsets FinishedSnapshotSplitsReportEvent{finishedOffsets={db_enterprise_8.t_report_detail_2016_4:27={ts_sec=0, file=mysql-bin.000382, pos=232441216, gtids=, row=0, event=0}}} from subtask 0. 2022-06-30 17:49:52,692 INFO com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator [] - Assign split MySqlSnapshotSplit{tableId=db_enterprise_8.t_report_detail_2016_4, splitId='db_enterprise_8.t_report_detail_2016_4:28', splitKeyType=[eid
CHAR(36) NOT NULL], splitStart=[e4f5b639-cdd4-466a-bc2a-092ad6a84348], splitEnd=[ed0193c7-e2ce-4942-b29b-704a3f961f48], highWatermark=null} to subtask 0 2022-06-30 17:49:53,291 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering checkpoint 3986 (type=CHECKPOINT) @ 1656582593242 for job 1749510150dc670c3e5dd92ef85b7e38. 2022-06-30 17:51:36,126 ERROR org.apache.flink.runtime.util.FatalExitExceptionHandler [] - FATAL: Thread 'SourceCoordinator-Source: MySQL Source181' 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: MySQL Source181,5,main] at org.apache.flink.runtime.source.coordinator.SourceCoordinatorProvider$CoordinatorExecutorThreadFactory.newThread(SourceCoordinatorProvider.java:119) [flink-cdc-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
知道呢,我之前在Flink 社区推动对应模块的同学修复过,是Flink 上的bug, 你可以用对应的bugfix版本,如果是内部有flink仓库,就把这两个bug的patch cherry-pick到你们内部flink分支 FLINK-24607 FLINK-23843(此答案整理自Flink CDC 社区)
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。