Flink CDC我在测试的时候遇到了一个问题,有个表有3400万数据,是联合主键的?
Flink CDC我在测试的时候遇到了一个问题,有个表有3400万数据,是联合主键的,但是cdc在同步的时候,只用了联合主键里面的一个key去拉数据,就导致这个where key >= ? 查到的数据量非常大,taskManger内存溢出了,这种情况有啥好的解决方案吗?
有大佬知道,Flink CDC中startscn什么时候更新吗?我现在实际测试发现oracle19c
有大佬知道,Flink CDC中startscn什么时候更新吗?我现在实际测试发现oracle19c,startscn在执行startlogmin方法9次之后才更新?是因为CK太慢才导致startscn不变吗?现在增量延迟大就是因为startscn总不变,约拖越慢,正常情况下应该每次startlog...
Flink CDC中oracle ddl语句能测试能抓取?
Flink CDC中oracle ddl语句能测试能抓取?
Flink CDC中mysql-cdc从时间戳启动,发现本地IDEA测试不行,什么原因?
Flink CDC中mysql-cdc从时间戳启动,发现本地IDEA测试不行,但是集群测试,是有数据出来,但是数据有问题呢。昨天插入了两条数据,时间戳设置为之前的,只有昨天插入的两条数据进来。今天测试了下,只有昨天插入的最后一条数据出来,是啥情况?我看binlog的失效时间是1个月的。
Flink CDC中经过测试,好像没生效,修改其他列 CDC也能收到update流。什么原因?
"问题1:Flink CDC中经过测试,好像没生效,修改其他列 CDC也能收到update流。什么原因?'debezium.column.include.list' = 'wit_account_3.accountinfo[0-9]+.project_id,wit_account_3.account...
Flink CDC中我想用cdc同步新增的数据但是在测试的时为什么写入到目标库的时候数据减少了很多?
Flink CDC中我想用cdc同步新增的数据,更新和删除的不管, 但是在测试的时候发现,写入到目标库的时候数据减少了很多 ,有知道可能是什么原因的吗?没对数据做任何出处理, 就是 source - filter - sink。
Flink CDC中我本地测试mysql-cdc从指定时间戳启动,一直没有成功呢是什么原因?
Flink CDC中我本地测试mysql-cdc从指定时间戳启动,一直没有成功呢是什么原因?使用的是dataStream的方式,flink的版本:1.15.3,mysql的版本:8.0.18, connector的版本:flink-connector-mysql-cdc 2.4.0。测试代码:
请问flink cdc中CDC2.4 测试发现在全量阶段有丢失更新的情况,什么原因?
请问flink cdc中CDC2.4 测试发现在全量阶段有丢失更新的情况,什么原因?
Flink CDC Datastream api在 cdc 2.4.0,官方有测试过么?
Flink CDC Datastream api在 cdc 2.4.0,官方有测试过么?
Flink CDC中sql 模式下 允许忽略部分算子状态 这个功能默认开启,自己测试下,虽然功能默?
Flink CDC中sql 模式下 允许忽略部分算子状态 这个功能默认开启,自己测试下,虽然功能默认开启,但是新增库、表第一次启动不会全量同步历史数据;需要单独启动一个任务全量同步之后,在老任务中加入待同步的库、表,然后从savepoint 启动?
更新时间 2023-09-08 04:15:08
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。