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

flink cdc跑多个MySQL到doris任务,报错数据库连接超时,还有其他什么地方需要配置?

flink cdc跑多个MySQL到doris任务,报错数据库连接超时,查看连接的数据库连接数及超时时间正常,请教大佬们还有其他什么地方需要配置?

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

Flink CDC看看是哪里配置错了吗?

Flink CDC看看是哪里配置错了吗?我看oracle-cdc里是有driver的,issues好像也有同样的问题

文章 2023-12-04 来自:开发者社区

Flink CDC配置中缺少了`mongo-cdc.start.at`参数导致的

这个问题可能是由于您的Flink CDC配置中缺少了mongo-cdc.start.at参数导致的。这个参数用于指定从哪个时间点开始读取数据,如果不设置该参数,则默认为null,这可能会导致同步过程中出现BsonInvalidOperationException异常。 您可以尝试在Flink CDC的配置文件中添加以下参数: mongo-c...

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

Flink CDC中server-id mysql cdc 抽取多个表是不是一般要配置好些?

Flink CDC中server-id mysql cdc 抽取多个表是不是一般要配置好些?

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

Flink CDC每张表都需要配置这个东西吗?因为遇到过server-id 冲突的情况?

Flink CDC每张表都需要配置这个东西吗?因为遇到过server-id 冲突的情况?

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

Flink CDC的配置又是什么作用?

Flink CDC的配置又是什么作用?classloader.check-leaked-classloader,Caused by: java.lang.IllegalStateException: Trying to access closed classloader. Please check if you store classloaders directly or indirectly ....

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

Flink CDC中mongo版本4.4,cdc胖包版本2.4.2,按照文档里这么配置的?

Flink CDC中mongo版本4.4,cdc胖包版本2.4.2,按照文档里这么配置的?mongodb集群1主1从CREATE TABLE ods_common_db.realtime_sync_logs( _id STRING PRIMARY KEY NOT ENFORCED, level STRING , loggerName STRING , messag...

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

Flink CDC flink捕捉不到cdc消息按照文档上的配置了变更流相关的权限?

Flink CDC中mongoCDC的吗,mongo的变更流貌似没有启用,flink捕捉不到cdc消息按照文档上的配置了变更流相关的权限?

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

Flink CDC中mysql cdc支持全量的时候并发读取,这个怎么配置呀?

Flink CDC中mysql cdc支持全量的时候并发读取,这个怎么配置呀?我使用了flink -p 命令指定了,但是task还是单并行度上面是jobManager的config已经显示配置了4个并行度,但是task执行的时候还是一个

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

Flink CDC如果binlog找不到配置的timestamp,任务是什么运行情况?

Flink CDC中mysql用timestamp启动,如果binlog找不到配置的timestamp,任务是什么运行情况?

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

产品推荐

实时计算 Flink

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

+关注