Flink CDC里你家用oracle cdc同步,是在源端是专门建了个表空间吗?

Flink CDC里你家用oracle cdc同步,是在源端是专门建了个表空间,把需要做同步的表建立到这个表空间上么?就用原来的用户账户,不动原来数据,赋予原来账户权限是么?

flink cdc 3.0中的源端 mysql中主键id是这个,后续怎么做?

flink cdc 3.0中的源端 mysql中主键id是bigint(20) unsigned,到目标端会转换成decimal(20,0),但要是目标端如starRocks中主键不支持decimal类型的话,就会报错,这个你遇到过吗?已经自己手动改了,但又发现时间格式同步到starRocks丢了精...

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

Flink CDC源端能忽略TRUNCATE操作么?

Flink CDC源端能忽略TRUNCATE操作么?

Flink CDC里如果源端 MySQL 主键是bigint unsigned 类型, 怎么转换?

Flink CDC里如果源端 MySQL 主键是bigint unsigned 类型, 转换成 cdc 类型为 decimal , 然后写到 starrocks 对应的类型为 decimal128 , StarRocks 不支持 decimal 作为主键的类型, 我也尝试过改 cdc 源码将 big...

Flink CDC源端是oracle19c 碰到这个问题过吗?

Flink CDC源端是oracle19c 碰到这个问题过吗?

Flink CDC数据同步作业开启之后,有没有好的数据对比方案,比较源端和目标端的数据是否一致?

Flink CDC数据同步作业开启之后,有没有好的数据对比方案,比较源端和目标端的数据是否一致(数量一致、内容一致等等)?

请教个Flink CDC问题。 现在框架里,如果源端设置的1个并行度,多个切片的情况下,每个切片的?

请教个Flink CDC问题。现在框架里,如果源端设置的1个并行度,多个切片的情况下,每个切片的高低水位肯定是不能完全衔接上,如果这些间隙内有数据变更,是不是就漏了?

Flink CDC中可不可以配置mysql源端控制提取变更数据的间隔 类似配置成每5秒获取变更数据?

Flink CDC中可不可以配置mysql源端控制提取变更数据的间隔 类似配置成每5秒获取变更数据这种?看源码里好像真没有TIMESTAMP,但是枚举里有定义oracle

大家好, Flink CDC中Mysql ->postgre 同步, 源端10个字段,Sink端?

大家好, Flink CDC中Mysql ->postgre 同步, 源端10个字段,Sink端10个字段, 但新建Finksql 时只建9个字段, 未匹配字段Flink 也会进行类型匹配检查并且如果不一致 会异常, 这块有什么解决办法吗, 想只检查进行匹配字段的类型?

Flink CDC中tidb cdc 只能当作源端 不能为目标端吗?把mysql的数据通过flink

Flink CDC中tidb cdc 只能当作源端 不能为目标端吗?把mysql的数据通过flink cdc 不能同步到tidb,Flink SQL> insert into t_tidb_flinkcdc select * from t_flinkcdc; [INFO] Submitting...

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载