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

Viewed 10
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
insert overwrite table 写入iceberg表报错
1 answers
期望Doris支持Apache Ozone对象存储ofs协议
1 answers
doris 3.0.4存算一体执行语句卡死并且kill失败
1 answers
FundationDB 问题 导致 FE 服务无法运行 及后续运维操作问题
1 answers
Doris 连接 Paimon 查询的时候报错ArrayIndexOutOfBoundsException
1 answers
Doris3.0.4使用paimon catalog连接带ssl证书的s3报错
2 answers