flink cdc connector读取mysql二进制主键导致任务失败
本文将探讨使用 apache flink cdc connector (版本 2.1.1) 读取 mysql 数据时遇到的问题。问题源于 mysql 表的主键使用了二进制格式，导致 flink 任务失败并抛出异常。
问题描述：
在使用 flink-connector-mysql-cdc 2.1.1 监听 mysql 数据库时，如果 mysql 表的主键是二进制类型，则会遇到如下错误：
[pool-79-thread-1] INFO io.debezium.jdbc.JdbcConnection - Connection gracefully closed[SourceCoordinator-Source: MySQL Source -> Sink: Print to Std. Out] ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator - Uncaught exception in the SplitEnumerator for Source Source: MySQL Source -> Sink: Print to Std. Out while handling operator event RequestSplitEvent (host='') from subtask 0. Triggering job failover.org.apache.flink.util.FlinkRuntimeException: Generate Splits for table 。。。 error ...Caused by: java.lang.ClassCastException: [B cannot be cast to java.lang.Comparable ...
登录后复制
本文来自互联网或AI生成，不代表软件指南立场。本站不负任何法律责任。
