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

Flink CDC我使用cdc从oracle同步数据到doris,数据全部加载到内存后,报错怎么办?

Flink CDC里我使用cdc从oracle同步数据到doris,这边将数据全部加载到内存后,报错如下:2024-01-09 15:11:00,825 WARN org.apache.flink.runtime.taskmanager.Task [] - Sink sink-doris.testdb.COMPINTRODUCTION (1/1)#0 (c...

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

Flink CDC全量和增量同步数据如何保证数据的一致性

Flink CDC全量和增量同步数据如何保证数据的一致性,不丢失和不重复读取?全量和增量是如何衔接的?

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

Flink CDC oracle cdc只能采集到最后一条数据,有没有遇到过的?

Flink CDC oracle cdc只能采集到最后一条数据,有没有大佬遇到过的?

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

请问下,flink cdc sql方式,当一条数据更新时,结果会输出1条数据还是2条数据?

请问下,flink cdc sql方式,当一条数据更新时,结果会输出1条数据(跟新后) 还是2条数据(更新前、更新后)?

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

Flink CDC同步的时候数据密码会定期变化,这个有什么办法解决没?

Flink CDC同步的时候数据密码会定期变化,这个有什么办法解决没?

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

各位flink cdc 同步进hudi的数据,可以用spark 改吗?

各位大哥flink cdc 同步进hudi的数据,可以用spark 改吗?

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

用flink cdc取到的数据是这样的 , 如何去加工成需要的样式?

用flink cdc取到的数据是这样的 , 如何去加工成需要的样式?

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

Flink CDC首次全量同步几百万数据,状态后端增量方式的rocksdb,正常的吗?

Flink CDC首次全量同步几百万数据,状态后端增量方式的rocksdb,目前Checkpointed Data Size 基本接近Full Checkpoint Data Size大小,正常的吗?ck耗时也很长,请问可以从哪些方面优化优化?

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

一样的代码,把Flink cdc从2.2升级到2.4.2同步不到pgsql的数据是什么原因?

一样的代码,把Flink cdc从2.2升级到2.4.2同步不到pgsql的数据是什么原因?也没有任何异常

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

Flink CDC中读取mongodb cdc,所有配置依赖等信息都正确,任务不报错但是读不到数据

经测试,相同连接配置和依赖的情况下,读取mongodb同一库下面不同集合,集合命名是'abc','abc_def'这种的读取没有问题。但是集合命名是以点分隔的 如:'abc.def.gh',数据无法读取,这种特殊命名集合应该如何处理才能读到数据~

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等