问答 2022-06-30 来自:开发者社区

请教一个问题,flink oracle cdc,读取一个没有更新操作的表,隔十几秒就重复读取全量数据

请教一个问题,flink oracle cdc,读取一个没有更新操作的表,隔十几秒就重复读取全量数据是怎么回事呀

问答 2022-06-29 来自:开发者社区

利用flink -cdc 同步 阿里云上polar db的数据到hologress上,connect

利用flink -cdc 同步 阿里云上polar db的数据到hologress上,connector用的是 'connector' = 'jdbc', 'driver' = 'org.postgresql.Driver', 发现porlardb中删除数据时,没办法同步到holo里,需要配置什么来解决这个问题呢

问答 2022-06-28 来自:开发者社区

Flink CDC动态加表,各位谁成功过吗?为啥新增的表读不到数据

Flink CDC动态加表,各位谁成功过吗?为啥新增的表读不到数据

问答 2022-06-27 来自:开发者社区

Flink CDC. 可以将mysql数据sink到 hbase么?

作为维表

问答 2022-06-22 来自:开发者社区

各位大佬,第一次使用flink mysql cdc, 现在程序启动 没报错 新增数据没有打印出来

请问可能的原因会是什么

问答 2022-06-22 来自:开发者社区

请问flink cdc在采集数据到kafka后,为什么多了这么多临时的主题

我这边生成kafka主题的逻辑是serp_表名,serp_ 还自动生成了serp_空的主题

问答 2022-06-22 来自:开发者社区

请问Flink的动态表是这样创建吗?我用flink cdc 读mysql数据,写flink动态表,发

请问Flink的动态表是这样创建吗?我用flink cdc 读mysql数据,写flink动态表,发现报错,提示必做要有 connector 配置。请问怎么解决呢?谢谢

问答 2022-06-21 来自:开发者社区

各位亲,flink cdc 在k8s容器跑。初始化数据正常,增量同步就没有了。容器的日志如附件。大家

各位亲,flink cdc 在k8s容器跑。初始化数据正常,增量同步就没有了。容器的日志如附件。大家谁知道啥原因啊?SET execution.checkpointing.interval = 3s; 后增量任务正常

问答 2022-06-21 来自:开发者社区

请问各位大佬,flink cdc在抽取oracle全量数据之前会加表级排他锁

请问各位大佬,flink cdc在抽取oracle全量数据之前会加表级排他锁,由于源端表数量大,在万张以上,锁表时长可能出现不可控的情况,而且对业务影响巨大。有没有方法解决这个问题

文章 2022-06-08 来自:开发者社区

【FlinkSQL实战系列】Flink SQL CDC 实时同步 Mysql 的 Binlog 数据到 kafka

什么是 CDC ?CDC,Change Data Capture,变更数据获取的简称,使用 CDC 我们可以从数据库中获取已提交的更改并将这些更改发送到下游,供下游使用。这些变更可以包括 INSERT,DELETE,UPDATE 等.要解决什么问题 ?使用 flink sql 进行数据同步,可以将数据从一个数据同步到其他的地方,比如 mysql、elasticsearch 等。可以在源数据库上实....

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

产品推荐

实时计算 Flink

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

+关注