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

Viewed 28
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
3.1.4版本routine load 文档上说支持，但是实际上不支持灵活列更新
1 answers
数据库备份恢复
1 answers
Stream Load时Http Connection aborted
1 answers
doris单节点fe出现了 Current group size:从1 变成2
2 answers
3.0.8版本 BE节点疯狂打印no such rowset ********
1 answers
Doris无法查询information_schema.tables表信息
1 answers