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

Viewed 39
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
doris3.0.8 3台中一台be节点偶发性宕机
2 answers
关于数值类型decimalv3兼容性问题
2 answers
ccr任务job_progress接口-子任务的binlog_type字段都有哪些枚举值
ccr数据同步成功了,但是执行get_lag的last_binlog_timestamp和first_binlog_timestamp为什么都是1970-01-01 08:00:00，我该怎么查看上次同步时间呢
1 answers
使用doris物化视图做数仓分层，哪种策略好
1 answers
物化视图创建-使用LATERAL VIEW EXPLODE_OUTER
2 answers