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

flink cdc oracle 读取不到表完整数据(只读取到1行,行总数:156),表没有主键没有

flink cdc oracle 读取不到表完整数据(只读取到1行,行总数:156),表没有主键没有unique,开启了数据库级最小补充日志,表级为补充日志为all ,有大佬知道这什么问题吗? flink1.15.3、cdc 2.3.0

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

大佬们,使用flink cdc 同步oracle的数据,如果归档日志被删除了,流任务重新拉起的话,还

大佬们,使用flink cdc 同步oracle的数据,如果归档日志被删除了,流任务重新拉起的话,还能读到oracle的数据吗?如果oracle的数据在一开始就没有开启归档日志,在开启归档日志之前的数据Flink cdc可以读取到吗?

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

使用 flink cdc讲数据写入到 以mor方式hudi中 同时配置将hudi元数据同步到hiv

使用 flink cdc讲数据写入到 以mor方式hudi中 同时配置将hudi元数据同步到hive上,使用presto查询外部表 只能查 外部表 ro 对于生成的rt 表查询报错,请问有使用presto查询hudi的吗?

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

请问flink cdc同步数据的时候遇到这个问题是什么情况呢?

请问flink cdc同步数据的时候遇到这个问题是什么情况呢?

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

我想问下,我现在启动Flink CDC 为什么会将我整张表的数据读取一边,可以不读取吗,只捕获增删改

我想问下,我现在启动Flink CDC 为什么会将我整张表的数据读取一边,可以不读取吗,只捕获增删改操作。我现在的表1kw,他直接给我读了一遍。

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

大佬们,我刚接触Flink CDC,同步Oracle数据,怎么感觉延迟很高?

大佬们,我刚接触Flink CDC,同步Oracle数据,怎么感觉延迟很高?

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

flink cdc 设置 sqlserver数据库 表140W条数据 直接写入 postgres

flink cdc 设置 sqlserver数据库 表140W条数据 直接写入 postgres数据库insert into TMATTOWORK_test2 select * from TMATTOWORK;数据插入postgres表80万条后报错,然后插入100W条后第二次报错--报错org.apache.flink.util.FlinkRuntimeException: Exceede...

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

请教大家一个问题,flink cdc有没有配置参数可以指定同步某个时间之后的增量数据, 比如只捕获3

请教大家一个问题,flink cdc有没有配置参数可以指定同步某个时间之后的增量数据, 比如只捕获3月1号之后的增量数据

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

flink cdc initial 模式, source表数据量过大,导致checkpoint

flink cdc initial 模式, source表数据量过大,导致checkpoint 一直 Checkpoint expired before completing. 有没有遇到过的大神指导一下如何优化呀?

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

我flink cdc实时同步MySQL数据,这个过程会产生binlog_dump行为吗?但是如果我按

我flink cdc实时同步MySQL数据,这个过程会产生binlog_dump行为吗?但是如果我按照这个 官网指定server_id,好像会有对应的serve_id的binlog_dump, 我问了chatgpt好像只有MySQL自己进行主从同步才会产生binlog_dump? 还有一点,我又测试别的数据库,flink cdc实时同步MySQL数据,又没有产生binlog_dump行为。

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

产品推荐

实时计算 Flink

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

+关注