问答 2023-12-04 来自:开发者社区

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,有遇到过么?

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,但是也没有输出,大家有遇到过么?

问答 2023-12-04 来自:开发者社区

Flink CDC任务总是报错这个怎么解决哇?

Flink CDC任务总是报错这个怎么解决哇?org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.se...

问答 2023-12-04 来自:开发者社区

Flink CDC创建pg数据源,这个报错谁遇到过啊?

Flink CDC创建pg数据源,这个报错谁遇到过啊?org.postgresql.util.psqlexception: The connection attempt failed.

问答 2023-12-01 来自:开发者社区

Flink CDC为什么会出现这个报错,同步Oracle的时候出现的?

Flink CDC为什么会出现这个报错,同步Oracle的时候出现的?Caused by: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and r....

问答 2023-12-01 来自:开发者社区

flink cdc 2.4.0 的是 guava30,我在依赖里面加了还是报错?

flink cdc 2.4.0 的是 guava30,我在依赖里面加了还是报错?

问答 2023-12-01 来自:开发者社区

Flink CDC同步Oracle时出现主题为空的报错怎么回事?

Flink CDC同步Oracle时出现主题为空的报错怎么回事?Caused by: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-e....

问答 2023-12-01 来自:开发者社区

Flink CDC如果类比我加了flink-connector-oracle-.jar的包会报错?

Flink CDC如果类比我加了flink-connector-oracle-cdc-2.4.2.jar的包会报错?不加flink-connector-oracle-cdc-2.4.2.jar任务job能启动,启动日志中有报错java.lang.NoClassDefFoundError: org/apache/kafka/connect/data/Schem;如果去掉flink-connecto....

问答 2023-12-01 来自:开发者社区

Flink CDC中mongodb 整库同步的时候报错 这个是咋回事?

Flink CDC中mongodb 整库同步的时候报错 这个是咋回事?Caused by: com.mongodb.MongoCommandException: Command failed with error 73 (InvalidNamespace): '{aggregate: 1} is not valid for '$changeStream'; a collection is re.....

问答 2023-12-01 来自:开发者社区

Flink CDC清理的话cdc程序不会报错吗?

Flink CDC清理的话cdc程序不会报错吗,我在我本地测试的删了之后cdc程序就报错了

问答 2023-12-01 来自:开发者社区

Flink CDC这种报错又是因为啥?

Flink CDC这种报错又是因为啥?Caused by: java.lang.RuntimeException: SplitFetcher thread 0 received unexpected exception while polling the records at org.apache.flink.connector.base.source.reader.fetcher.Spl...

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

产品推荐

实时计算 Flink

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

+关注