开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

这个问题知道吗?

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:?]

展开
收起
游客3oewgrzrf6o5c 2022-06-30 18:29:44 1414 0
1 条回答
写回答
取消 提交回答
  • 知道呢,我之前在Flink 社区推动对应模块的同学修复过,是Flink 上的bug, 你可以用对应的bugfix版本,如果是内部有flink仓库,就把这两个bug的patch cherry-pick到你们内部flink分支 FLINK-24607 FLINK-23843(此答案整理自Flink CDC 社区)

    2022-07-03 14:40:31
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

热门讨论

热门文章

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载