问答 2023-09-06 来自:开发者社区

Flink CDC消费pulsar 消息经常出现这个报错?

Flink CDC消费pulsar 消息经常出现这个报错?请教各位大佬是什么原因造成的?

问答 2023-08-29 来自:开发者社区

Flink CDC mysql cdc,连接数据库报错是什么原因?

Flink CDC mysql cdc,连接数据库报错是什么原因?数据库手动连接没有问题

问答 2023-08-29 来自:开发者社区

Flink CDC接sqlserver的时候报错?

Flink CDC接sqlserver的时候报错?java.lang.IllegalArgumentException: The column "ID" is referenced as PRIMARY KEY, but a matching column is not defined in table ""! at io.debezium.pipeline.source.Abstract...

问答 2023-08-29 来自:开发者社区

大佬们,Flink CDC连接MySQL启动太久了之后就会报错这个是什么情况哦?

大佬们,Flink CDC连接MySQL启动太久了之后就会报错这个是什么情况哦?

问答 2023-08-28 来自:开发者社区

大佬,Flink CDC 中我使用MySQL cdc 2.2.1版本。遇到这个报错请教下该怎么解决?

问题1:大佬,Flink CDC 中我使用MySQL cdc 2.2.1版本。遇到这个报错请教下该怎么解决呢。我的代码中没有时间转换的代码,感觉像debezium解析的问题?问题2:不是,出现了这个问题,想看看升级到2.4.1版本能不能解决的,但是升到2.4.1版本报这个错误

问答 2023-08-28 来自:开发者社区

Flink CDC 请问这个报错是什么原因啊?

Flink CDC 请问这个报错是什么原因啊?Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath. ?

问答 2023-08-23 来自:开发者社区

Flink CDC mysql5.7,请问官方说驱动要用8.0.28,报错获取不到这个变量:?

Flink CDC mysql5.7,请问官方说驱动要用8.0.28,报错获取不到这个变量:com.mysql.cj.CharsetMapping.COLLATION_INDEX_TO_COLLATION_NAME 从8.0.26这个变量就变成私有了,请问是我Flink 吃点菜版本用错了吗,我用的是2.0.0?

问答 2023-08-22 来自:开发者社区

Flink CDC有大佬遇到过这个报错吗?

Flink CDC有大佬遇到过这个报错吗?

问答 2023-08-22 来自:开发者社区

Flink CDC我根据这个添加的代码,现在报错Caused by: java.lang.?

Flink CDC我根据这个添加的代码,现在报错Caused by: java.lang.ClassCastException: org.apache.kafka.connect.data.SchemaBuilder cannot be cast to com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.data.Schema....

问答 2023-08-22 来自:开发者社区

Flink CDC的时候是不是有buffer,为什么doris数据库没有数据,也不报错?

问题1:Flink CDC的时候是不是有buffer,为什么doris数据库没有数据,也不报错?问题2:为什么开下checkpoint就可以了?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注