问答 2023-07-02 来自:开发者社区

Flink CDC归档的时候采集数据会报错,不知道怎么解决?

Flink CDC归档的时候采集数据会报错,不知道怎么解决?

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

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

各位大佬,有做过flink 作业轮巡运行的案例吗?我这边有1000+采集作业,增量数据都不大。想搞一个轮巡机制,每次跑100个作业。跑一会自动停止,再跑下一批,是滴,目前考虑了ds

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

咨询下,大家用Flink CDC采集数据之后,下游是怎么消费的?有用MQ接收的吗?现在碰到一个问题,

咨询下,大家用Flink CDC采集数据之后,下游是怎么消费的?有用MQ接收的吗?现在碰到一个问题,下游如果用MQ接收(不可改变),配置多个消费者的话,如何保证消息消费的顺序一致性呀?比如如果用pulsar的shared的模式,顺序就错乱了。如果用其他的模式,又会引发单节点问题,以及动态调整消费节点的复杂度,请问有什么建议处理这种场景呢?

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

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

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

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

请问,flink-cdc采集Postgresql数据时,对Postgresql的等时间格式的格式方?

请问,flink-cdc采集Postgresql数据时,对Postgresql的timestamp、date等时间格式的格式方案是什么?

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

请问一下Flink CDC 中有没有使用CDC采集oracle19c的,采集数据很慢有大佬解决的吗

请问一下Flink CDC 中有没有使用CDC采集oracle19c的,采集数据很慢有大佬解决的吗

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

大佬们,问个小白问题,flink cdc不是只能单线程采集数据,然后把采集的数据放到kafka,ka

大佬们,问个小白问题,flink cdc不是只能单线程采集数据,然后把采集的数据放到kafka,kafka,5个分区,你们说并行度设置多少合适?用yarn per job提交, -Dparallelism.default,设置成多少?跟kafka分区数一致,说设置成5,还是跟源头一样,直接设置成1

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

flink1.15 cdc2.3,本地采集mysql数据,运行一会,总会报这种错误,有大佬遇到过吗?

flink1.15 cdc2.3,本地采集mysql数据,运行一会,总会报这种错误,有大佬遇到过吗?

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

用flink cdc采集oracle数据,出现这个问题“无法从套接字读取更多的数据”flink 版本

用flink cdc采集oracle数据,出现这个问题“无法从套接字读取更多的数据”flink 版本1.13.0 oracle cdc版本 2.1.0,有遇到的吗?

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

Flink CDC实时采集 48小时没有数据来就报错 , 你们有遇到过吗?

Flink CDC实时采集 48小时没有数据来就报错 , 你们有遇到过吗?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注