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

Flink CDC里一般怎么解决维表更新问题,维表数据可能比主表数据后到的情况怎么办?

Flink CDC里一般怎么解决维表更新问题,维表数据可能比主表数据后到的情况,我看官方文档有个look up hint 的功能,所以来试试怎么搞?

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

Flink CDC里mysqlcdc 源库有2张表一下子更新几万条数据 任务会挂掉 这种情况 ?

Flink CDC里mysqlcdc 源库有2张表一下子更新几万条数据 任务会挂掉 这种情况 有什么好的办法? 除了增加内存。

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

Flink CDC里我通过oracle的connector往hudi插入数据,为什么不变 ?

Flink CDC里我通过oracle的connector往hudi插入数据,flink web ui里面为啥Sink: clean_commits 这个步骤并行度是1,我设置的默认并行度是5,但是它改变不了为什么?

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

Flink CDC里cdc mongo 碰到这样的数据咋处理?

Flink CDC里cdc mongo 碰到这样的数据"freightrates":{"$numberLong":"100000"},你们是咋处理的?

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

Flink CDC我配置mysql CDC,但任务重启(重新执行)后,它总是全量同步数据,要怎么做?

Flink CDC里我配置mysql CDC,但是任务重启(重新执行)后,它总是全量同步数据,具体有什么参数可以配置使用增量同步啊?

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

Flink CDC里flink orcle-cdc-2.3.0在获取oralce数据时报错为什么啊?

Flink CDC里flink orcle-cdc-2.3.0在获取oralce数据时报错。报错内容如下:io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuratio....

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

Flink CDC里问下增量数据可以不写进kafka,直接写进下游数据库吗?

Flink CDC里问下增量数据可以不写进kafka,直接写进下游数据库吗?

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

Flink CDC里集群偶发性的报这个错误,对数据有影响吗?

Flink CDC里集群偶发性的报这个错误,我们用的yarn,遇到这个错误,任务自动重启,容器就换了,对数据有影响吗?

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

Flink CDC里建了一张upsert-kafka的flink表,但是数据为空怎么办?

Flink CDC里建了一张upsert-kafka的flink表,但是数据为空。topic里面是有数据的。这个现象正常么?topic里有两条数据,只不过数据内容一样

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

Flink CDC里mysql做为CDC源,写入到kafka时报错,无法处理有更新和删除的数据咋办?

Flink CDC里mysql做为CDC源,写入到kafka时报错,无法处理有更新和删除的数据。这个问题怎么解决?除了upsert-kafka连接器,正常的kafka连接器是不支持删除和更新的,而数据库支持增删改,所以才不能写入到kafka。但是如果有数据库写入到kafka的需求,不知道该怎么处理?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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