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
job里面执行的task的状态finished和success的区别
1 answers
Flink-Doris-Connector写入数据到Doris，checkpoint卡住
1 answers
BE Not Alive指标抖动严重，查看BE进程正常没有重启
1 answers
物化视图自动刷新
1 answers
be警告日志全部打印Query xxx does not exists, failed to cancel it
1 answers
type:LOAD_RUN_FAIL; msg:errCode = 2, detailMessage = type:LOAD_RUN_FAIL; msg:errCode = 2,
1 answers