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

在一个Flink CDC程序里面,对mysql中多张表分别建立source,这样有什么区别吗?

在一个Flink CDC程序里面,对mysql中多张表分别建立source,再写入对应的sink;与使用dblist,tablelist建立一个source,写入多个对应的sink;这样有什么区别吗?

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

Flink CDC中报线程池问题 我把source表的调到100 也是数据库限制了吗?

Flink CDC中报线程池问题 我把source表的调到100 也是数据库限制了吗?

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

Flink CDC以前旧版本cdc2.2.1默认一个source表下如果不配置线程池,默认是多少个?

Flink CDC以前旧版本 cdc2.2.1 默认一个source表下如果不配置线程池,默认是多少个,现在如果很多source表,每个最低给1个 会不会产生大量的连接呢?

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

Flink CDC没报错,但数据不同步,修改source表数据,sink表没变,为什么?

Flink CDC通过flinksql的方式 flink 1.14.6 cdc 2.4.2 测试souce表以下两种增量同步,都没成功过,'scan.startup.mode' = 'specific-offset','scan.startup.specific-offset.file' = 'mysql-bin.000268','scan.startup.specific-offse...

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

Flink CDC中source、sink对flink来说对一个算子确实没有内外部,同步了多少的量?

Flink CDC中source、sink对flink来说对一个算子确实没有内外部,我想了解下能不能获取外部系统-一个算子的source有多少条数呢,比如mysqlcdc同步mysql的数据,同步了多少的量?

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

Flink CDC中transform里面的source支持多张表吗?

Flink CDC中transform里面的source支持多张表吗?

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

Flink CDC在官网看CDC 2.4版本的文档,在创建Source的时候,部分参数找不到?

Flink CDC在官网看CDC 2.4版本的文档,在创建Source的时候,部分参数找不到。 我自己的IDEA截图 ?

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

Flink CDC增量source 并行度1,导致的拉取数据处理不过来,这个有啥优化方案吗?

Flink CDC增量source 并行度1,导致的拉取数据处理不过来,flink下游的数据量明显低于mysql数据量,造成延迟。这个有啥优化方案吗?

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

Flink CDC增量source 并行度1,导致消费不到binlog,这个有没好的优化方案?

Flink CDC增量source 并行度1,导致消费不到binlog,导致延迟。这个有没好的优化方案?

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

Flink CDC单表发现修改并行度后source和sink端都是1,是只能为1还是可以修改?

Flink CDC单表发现修改并行度后source和sink端都是1,是只能为1还是可以修改?

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

产品推荐

实时计算 Flink

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

+关注