文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之在进行数据同步时,重新创建了一个新的任务,但发现无法删除旧任务同步的历史数据,是什么导致的

问题一:有没有 知道 flink operator 默认添加的这个 confimap 我怎么修改啊 ? 有没有 知道 flink on k8s operator , operator 默认添加的这个 confimap 我怎么修改啊 ?我重新制作了一个flink 镜像 修改了 log4j-console.properties 但是容器启动后 还是用 原来 的log4j-console.pr...

实时计算 Flink版产品使用问题之在进行数据同步时,重新创建了一个新的任务,但发现无法删除旧任务同步的历史数据,是什么导致的
问答 2024-07-02 来自:开发者社区

对于Flink CDC,从mysql到doris数据同步,同步位点信息存在哪里?

对于Flink CDC,从mysql到doris数据同步,同步位点信息存在哪里?

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之在进行数据同步时,修改了YAML文件以增加新的同步表并取消了之前的同步任务,如何从之前的检查点继续执行

问题一:flink cdc 3.0 使用pipeline方式同步数据,中断任务后怎么继续之前的任务断点? flink cdc 3.0 使用pipeline同步数据时,如果改动yaml文件已增加新的同步表,取消了之前的同步任务,修改后的任务怎么继续之前的检查点。现在是每次重新提交任务都会重新处理一遍之前同步过程。 参考答案: 在使用 Flink CDC ...

问答 2024-06-05 来自:开发者社区

在Flink CDC中数据同步过程中 mysql有几何字段 这种一般怎么同步到pg数据库呢?

在Flink CDC中数据同步过程中 mysql有几何字段 这种一般怎么同步到pg数据库呢?

问答 2024-05-29 来自:开发者社区

Flink读取CDC全量数据同步没有异常但是无法同步增量数据

Flink读取CDC全量数据同步没有异常但是无法同步增量数据

文章 2024-05-23 来自:开发者社区

实时计算 Flink版操作报错之在使用Flink CDC进行数据同步时遇到了全量同步不完全的问题,同时有任务偶尔报错,是什么原因

问题一:Flink CDC这个报错是啥意思么? Flink CDC这个报错是啥意思么? 把mongo的胖包放进去之后,jobmanager直接没起来 参考回答: 这个报错可能是由于Flink...

实时计算 Flink版操作报错之在使用Flink CDC进行数据同步时遇到了全量同步不完全的问题,同时有任务偶尔报错,是什么原因
问答 2024-05-20 来自:开发者社区

Flink CDC里mysql-cdc 做全量历史数据同步的时候如何控制同步速度么?

Flink CDC里mysql-cdc 做全量历史数据同步的时候如何控制同步速度么?调整chunk-size参数大小么?想限速 用cdc-pipeline 下游doris的io负载有些高,配置还行 3fe 3be 32GB 128GB。替换库名,是的 配置没啥问题 但cdc的参数用的也都是默认的 scan.incremental.snapshot.chunk.size:8096scan.sn...

问答 2024-05-01 来自:开发者社区

Flink CDC做数据同步的时候 pg的bit(1) 怎么同步到pg另一个表的bit(1) 里去?

Flink CDC里做数据同步的时候 pg的bit(1) 怎么同步到pg另一个表的bit(1) 里面去 ?

阿里云文档 2024-03-29

如何快速构建一个从Kafka到Hologres的数据同步作业

Flink全托管产品提供丰富强大的日志数据实时入仓能力。本文为您介绍如何在Flink全托管控制台上快速构建一个从Kafka到Hologres的数据同步作业。

文章 2024-02-24 来自:开发者社区

Flink CDC数据同步问题之同步数据减少如何解决

问题一:Flink CDC现在支持从oracle备库同步数据吗? Flink CDC现在支持从oracle备库同步数据吗? 参考答案: 备库不支持的要主库 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/538438?spm=a2c6h.13066369.que...

Flink CDC数据同步问题之同步数据减少如何解决

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