io.debezium.connector.mysql.MySqlOffsetContext.getSourceInfo()Lorg/apache/flink/cdc/connectors/shaded/org/apache/kafka/connect/data/Struct;

Question

版本按照官方文档使用的flink1.18 + flink-sql-connector-mysql-cdc-3.1.1 + flink-doris-connector-1.18-24.0.0.jar

qingchunweimian · Answer

版本不兼容问题，flink-doris-connector-1.18-1.6.2.0.0.jar