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

有大佬在阿里云E-MapReduce线上用过Flink cdc CDAS 同步数据到SR的吗?

有大佬在阿里云E-MapReduce 线上用过 Flink cdc CDAS 从 mysql 分库分表同步数据到SR的吗?库和表比较多的话性能ok吗?

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

各位大佬,麻烦问下,Flink CDC中tidb_cdc,采集tidb的数据,通过streampa?

各位大佬,麻烦问下,Flink CDC中tidb_cdc,采集tidb的数据,通过streampark来采集,没有报错,任务正常运行,但是采集不到数据,为啥呢?

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

问下:Flink CDC中查一遍数据库的数据,是基于表查还是基于日志文件? 如果binlog是后面加

问下:Flink CDC中查一遍数据库的数据,是基于表查还是基于日志文件? 如果binlog是后面加的,没有历史数据,应该查不到吧?

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

Flink CDC报错不支持 要解决的问题是数据出现反压 读取速度远远大于写入速度么?

我flink1.13.6版本的sql cdc怎么分别设置source和sink并行度 直接写到with参数里面报错不支持 要解决的问题是数据出现反压 读取速度远远大于写入速度?是sql操作的 写到with参数里报错不支持

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

我这边遇到个Flink CDC问题新增的分表采集不到数据,版本是2.4.0,有没有大佬了解是个啥原因

我这边遇到个Flink CDC问题,就是table-name给的正则表达式,数据库有按日期分表,新增的分表采集不到数据,版本是2.4.0,有没有大佬了解是个啥原因?重启下是有了,但是有两个问题,第一个,每天要重启这个有点麻烦了,第二个,现在周末两天的那两张分表数据我得手动用批量导入工具补数据。。

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

Flink CDC中第二次ckp时,处理的MySqlSnapshotSplit 不会覆盖第一次数据?

Flink CDC中第二次ckp时,处理的MySqlSnapshotSplit 不会覆盖第一次MySqlBinlogSplit的数据吗?

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

使用flink cdc 同步数据到sr 有使用界面化的任务配置管理工具吗?

使用flink cdc 同步数据到sr 有使用界面化的任务配置管理工具吗?

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

Flink CDC中mysql-cdc隔一段时间我消费一次数据,发现就会相比之前少一些,这可能是什么

Flink CDC中mysql-cdc的从指定时间戳(在binlog有效期之内)启动,指定的时间戳不变,但是隔一段时间我消费一次数据,发现就会相比之前少一些,这可能是什么原因?

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

Flink CDC中给维表加ttl缓存的那个,他的缓存逻辑是什么?是会提前缓存好一批数据?

问题1:Flink CDC中给维表加ttl缓存的那个,他的缓存逻辑是什么?是会提前缓存好一批数据?还是只是把流表关联的时候用到过的查过来的数据缓存?问题2:怎么感觉这个ttl设置不顶用呀?我只给他设置了30秒,没看出来他过期了,跑了四十多分钟后还是内存溢出崩掉了。

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

Flink CDC中数据库cdc任务启动后第二天数据库里新建的表 没有读到数据,怎么办?

Flink CDC中数据库有表按天分区,cdc任务启动后,第二天数据库里新建的表 没有读到数据,怎么解决?是正则写的有问题吗?^db.tableName\d{4}\d{2}_\d{2}$

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等