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

Viewed 46
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可以使用JOB创建定时任务吗
1 answers
Doris CASE WHEN 嵌套 IF 查询精度丢失情况
1 answers
无法访问es的catalog, 感觉功能上有瑕疵
2 answers
【严重故障】doris create table 卡住，死锁，重启fe节点才能恢复服务
1 answers
服务于智能体的Doris湖仓架构该怎么画
1 answers
doris3.1.4查询报错The specified scan snapshotId 97906 is out of available snapshotId range [1, 1]
1 answers