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

Viewed 17
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
fe集群加入失败
show backends； 单节点be如何修改host
Doris从3.0.3升级到3.0.8遇到的问题？
doris 3.1.1 中 使用LEAST、GREATEST 函数，相同的变量会因为不同精度返回不一样的结果
Doris从2.1.11升级至3.0.8后streamload效率变慢
doris manager 创建存算分离集群时，hdfs storage vault 怎么使用高可用连接而不是单一连接一个namenode