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.1.3版本routine load报错
BE内存无法回收的问题
1 answers
Spark Doris Connector 从hive导入doris double类型丢精度怎么解决？
1 answers
doris3.0.8运行insert into 任务报错send fragments failed. io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED
2 answers
tablet冷却期间be故障，冷却中的tablet状态无法恢复
1 answers
节点故障恢复，tablet副本无法不均衡，删除节点重新添加也不行