问答 2023-12-20 来自:开发者社区

Flink CDC消费kafka中的数据,之前能正常消费。现在报这种,有遇到过么?

Flink CDC消费kafka中的数据,之前能正常消费。现在报这种,大佬们有遇到过么?

问答 2023-12-20 来自:开发者社区

使用【flink cdc】的方式从【oceanbase数据库】同步数据到是什么原因导致的呢?

使用【flink cdc】的方式从【oceanbase数据库】同步数据到【doris 数据库】,期间遇到了这么一个报错 【unsupported protocol version】,是什么原因导致的呢? 如何解决这个报错?flink 版本: 1.15.0flink-sql-connector-oceanbase-cdc 版本: 2.2.0oceanbase 版本: 4.2.1oblogproxy....

问答 2023-12-20 来自:开发者社区

Flink CDC中oracle cdc获取到数据修改时候会有这个错,有知道这是啥问题吗?

Flink CDC中oracle cdc获取到数据修改时候会有这个错,有兄弟知道这是啥问题吗?file is not a valid field name,at org.apache.kafka.connect.data.Struct.lookupField(Struct.java:254)这个时候报的?

问答 2023-12-20 来自:开发者社区

Flink CDC中flink sql查询数据的时候,经常出现这种报错是什么原因啊?

Flink CDC中flink sql查询数据的时候,经常出现这种报错是什么原因啊?[ERROR] Could not execute SQL statement. Reason:org.apache.flink.shaded.netty4.io.netty.channel.ConnectTimeoutException: connection timed out: localhost/127.....

问答 2023-12-20 来自:开发者社区

Flink CDC怎么在ElasticSearch中查看同步的数据啊?

Flink CDC怎么在ElasticSearch中查看同步的数据啊?

问答 2023-12-20 来自:开发者社区

Flink CDC中mongo cdc 2.3 新任务,捕获完所有数据,有遇到过吗?

Flink CDC中mongo cdc 2.3 新任务,捕获完所有数据(期间表数据没有更变),然后关闭任务并保存savepoint,然后在mongo表里面删除一条或者多条记录,然后再使用savepoint恢复过程的任务,删除操作没有被正常捕获,(在保存savepoint前,表数据进行更改,那么使用savepoint恢复,就可以捕获删除操作) 有遇到过吗?

问答 2023-12-20 来自:开发者社区

Flink CDC使用的是kafka canal json作为数据变更源,cdc3.0未来会支持么?

Flink CDC使用的是kafka canal json作为数据变更源,cdc 3.0未来会支持么?

问答 2023-12-20 来自:开发者社区

flink cdc 读取MySQL数据,这种一般手动指定是u不是会规避这种情况?

在使用Flink CDC读取MySQL数据时,如果没有手动指定server-id,会报告有相同的server-id错误。一般来说,手动指定server-id可以规避这种情况。但是,手动指定server-id时如何确保与MySQL主从同步使用的不重复?又如何知道哪些server-id尚未使用?另外,为什么Flink CDC默认分配的server-id会重复?

问答 2023-12-20 来自:开发者社区

Flink CDC那个批量删数据导致序列化异常,这个问题修复了么?

Flink CDC那个批量删数据导致序列化异常,这个问题修复了么?

问答 2023-12-20 来自:开发者社区

使用3.0.0的Flink CDC同步8年历史数据发现丢失了两天的数据,请问有丢数据的case吗?

使用3.0.0的Flink CDC同步8年历史数据发现丢失了两天的数据,请问有丢数据的case吗?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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