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

Flink CDC有没有oceanbase的demo,我找来找去只找到mysql的data 例子?

Flink CDC有没有oceanbase的demo,我找来找去只找到mysql的data stream例子?我这段代码会报空指针

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

Flink CDC中mysql cdc全量阶段可以多并行度云行,并行度是单并行度还是多并行度呀?

Flink CDC中mysql cdc全量阶段可以多并行度云行,全量转增量后,并行度是单并行度还是多并行度呀?

高性能

基于 Flink CDC 打造企业级实时数据同步方案

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 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中MySQL同步表时,有人了解这个有什么解决办法吗?

Flink CDC中MySQL同步表时,我通过createStatementSet创建StatementSet,来同时跑多个Insert语句,发现StatementSet不能对jobName命名,想对源码重构,发现TableEnvironmentInternal接口的executeInternal抽象方法也没有这种命名任务的,有人了解这个有什么解决办法吗,希望能交流下经验?

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

Flink CDC中mysql cdc ,整库同步,加载历史数据多表之间时串行的吗?

Flink CDC中mysql cdc ,整库同步,加载历史数据多表之间时串行的吗?增加并行度貌似并没有起效果?

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

Flink CDC中mysql cdc 的那个server_id 设置的话,一般是怎么设置的?

Flink CDC中mysql cdc 的那个server_id 设置的话,一般是怎么设置的来,我设置 44200 报超出范围了,这个的设置范围不太了解?

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

Flink CDC同步MySQL分库分表500张表报连接超时,方便帮忙看一下吗?

Flink CDC同步MySQL分库分表500张表报连接超时,方便帮忙看一下吗?这个库别的分表是没有问题的,就这个分库分表?

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

Flink CDC中mysql和sqlserver放在一起跑之后,flink集群报了上面这个错误?

Flink CDC中mysql和sqlserver放在一起跑之后,flink集群报了上面这个错误?

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

Flink CDC中MySQL 进行cdc的用户需要什么权限?

Flink CDC中MySQL 进行cdc的用户需要什么权限?

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

Flink CDC有同时在flink集群里面,跑mysql+sqlserver的参考代码么?

Flink CDC有同时在flink集群里面,跑mysql+sqlserver的参考代码么?用的是flink-sql方式,但是很奇怪,flink-connector-mysql-cdc-2.2.1.jardebezium-connector-mysql-1.5.4.Final.jarflink-sql-connector-mysql-cdc-2.2.1.jar上面的包少了任何一个,都跑不起来。

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

产品推荐

实时计算 Flink

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

+关注