Apache Doris 中文技术论坛
Questions Tags Users Badges

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

Asked Oct 23, 2024 Modified Jan 1, 0001
Viewed 24
3.0

版本按照官方文档使用的flink1.18 + flink-sql-connector-mysql-cdc-3.1.1 + flink-doris-connector-1.18-24.0.0.jar

edited Jan 1, 0001
qingchunweimian1
asked Oct 23, 2024
1 Answers

版本不兼容问题,flink-doris-connector-1.18-1.6.2.0.0.jar

edited Jan 1, 1970
qingchunweimian1
answered Oct 23, 2024
Related Questions
是Doris 备份上到hdfs 中,现在100m大小左右表,上传那一步很慢要1小时,什么原因
1 answers
spark读取doris库datetime类型9999-09-09 00:00:00发生错乱为1978-01-12 02:47:02
3.0.3的异常停止后,启动fe报错,有大佬遇见过这个问题吗?
1 answers
启动doris be失败,<jemalloc>: Number of CPUs detected is not deterministic. Per-CPU arena disabled.
flink实时写入doris内部表报错
1 answers
单个集群的tablet总数最大不建议超过多少呢?
1 answers

Terms of service Privacy policy

Powered by Answer - the open-source software that powers Q&A communities.
Made with love © 2026 Apache Doris 中文技术论坛.