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

咨询个Flink CDC问题,如果oracle数据单表数据变更要关联多表查询,是把多表数据都导入在?

咨询个Flink CDC问题,如果oracle数据单表数据变更要关联多表查询,是把多表数据都导入在flink中计算,还是用单表增量数据通过数据库进行关联查询呢?

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

Flink CDC数据到kafka,同一个主键的所有数据都会放到一个分区吗?

Flink CDC数据到kafka,同一个主键的所有数据都会放到一个分区吗?

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

大佬们,请教个Flink CDC问题:我想从原始表中过滤掉部分数据 插入新表;在flinkcdc ?

大佬们,请教个Flink CDC问题:我想从原始表中过滤掉部分数据 插入新表;在flinkcdc 有什么好的方案吗?

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

请问在使用Flink CDC中mongo cdc的时候,全量数据同步完成后,不会同步增量数据,这种?

请问在使用Flink CDC中mongo cdc的时候,全量数据同步完成后,不会同步增量数据,这种问题有人遇到过吗,我建了一个issue: https://github.com/ververica/flink-cdc-connectors/issues/2183?增量数量的量不小,我直接用mongo change stream是可以拉到数据的

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

Flink CDC 中mysql到mysql数据实时同步,大概有100多张表,flink cdc能?

Flink CDC 中mysql到mysql数据实时同步,大概有100多张表,flink cdc能抗住嘛?

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

Flink CDC 怎么才能同步多个表的数据呀?好像不支持正则,我按照mysql的写法写上去一个表也

Flink CDC 怎么才能同步多个表的数据呀? postgres好像不支持正则,我按照mysql的写法写上去一个表也读不到

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

大佬 我发现Flink CDC出来的数据比我MYSQL数据要多 什么情况?

大佬 我发现Flink CDC出来的数据比我MYSQL数据要多 什么情况?select 1234 as id, count(distinct(papers_number)) as user_num from biz_user where papers_number is not null cdc写mysql,读mysql 写mysql

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

各位大佬知道,Flink CDC需要配置什么东西嘛?,才能触发同步?变更数据了,感觉没同步,配置了这

各位大佬知道,Flink CDC需要配置什么东西嘛?,才能触发同步?变更数据了,感觉没同步,配置了这个 debezium.snapshot.mode 只有启动的时候同步,多表关联的,checkpoint 配置了5秒,两张表关联查询数据,然后插入sink表,修改了某一张表的数据,同步不了

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

把 Flink CDC的数据 经过Doris 连接器写入Doris ,同时从checkpoint断?

把 Flink CDC的数据 经过Doris 连接器写入Doris ,同时从checkpoint断开的位置恢复。 现在遇到的是从checkpoint恢复时,还是从头开始拉取的数据。 有大佬知道咋处理吗?

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

各位大佬,有做过Flink CDC作业轮巡运行的案例吗?我这边有1000+采集作业,增量数据都不大。

问题1:各位大佬,有做过Flink CDC作业轮巡运行的案例吗?我这边有1000+采集作业,增量数据都不大。想搞一个轮巡机制,每次跑100个作业。跑一会自动停止,再跑下一批?提前以配置表的形式配好 问题2:主要是现在流程我都没跑通,请问一下这个Default 20 是在哪里配置的?我都没找到

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

产品推荐

实时计算 Flink

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

+关注