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

Viewed 12
3.0

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

1 Answers

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

qingchunweimian1
Related Questions
Doris 3.1 存算分离模式清理缓存
无法生成image文件
1 answers
Doris 3.1 Jmeter 测试
1 answers
doris be查询负载未均衡
1 answers
海光服务器兼容问题
Doris 3.1 manager webui查询
1 answers