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
Doris部署架构推荐
1 answers
doris3.0.5版本，执行查询和插入时候数据量不一致
1 answers
通过enable_audit_plugin开启审计日志，audit_log表创建了但是没有数据
1 answers
Doris 3.0.7 存算分离FE内存泄露问题
1 answers
随便插入一条数据be就挂掉了，数据也无法正常插入
1 answers
Doris一直循环报错DATA_QUALITY_ERROR，应该如何定位和解决这个问题
1 answers