问答 2024-03-11 来自:开发者社区

Flink CDC 里我在尝试flink mysql cdc :3.0.1 获取数据未果,该怎么办?

Flink CDC 里我在尝试flink mysql cdc :3.0.1 从可提供的元数据中获取row_kind字段,可是却在报错日志中说不可获取。具体的问题如下面url:https://github.com/apache/flink-cdc/issues/3117 , 请问有人遇到相同问题吗?

问答 2024-03-11 来自:开发者社区

Flink CDC 里获取数据报错怎么修复?

Flink CDC 里flink-1.16.2 , mysql-cdc3.0.0(3.0.1)获取数据报错,这个怎么修复?

问答 2024-03-11 来自:开发者社区

flink cdc 读取mysql数据写入hudi表中,为什么出现这种情况?

flink cdc 读取mysql数据写入hudi表中,再用flinksql查询hudi表数据写入另一个hudi表中,源表数据删除,第一个hudi表中数据成功删除,第二个hudi表中数据没有删除。有大神知道怎么回事吗?

问答 2024-03-11 来自:开发者社区

Flink CDC 里这个命令不报错 但是没有获取到数据 是为什么?

./bin/flink run lib/paimon-flink-action-0.8-20240301.002155-30.jar mongodb_sync_database --warehouse 'hdfs://10.67.78.243:8020/paimon/mongodb' --database EHR_DATA --mongodb_conf hosts=10.67....

问答 2024-03-11 来自:开发者社区

Flink CDC 里我用oracle2.4.2来拉取oracle的数据,结果报空指针为什么?

Flink CDC 里我用oracle2.4.2来拉取oracle的数据,结果报空指针,这个是什么问题?就只是打印还有没有处理数据

问答 2024-03-11 来自:开发者社区

Flink CDC 里有用datastrea来cdc oracle数据的吗?

Flink CDC 里有用datastrea来cdc oracle数据的吗?

问答 2024-03-11 来自:开发者社区

请问 flink cdc可以处理doris 数据吗?

请问 flink cdc可以处理doris 数据吗?

问答 2024-03-11 来自:开发者社区

Flink CDC 里我在代码中是这样写的,为什么还是将全量数据读取了?

/配置读取位置/properties.setProperty("scan.incremental.snapshot.enabled","true");properties.setProperty("scan.startup.mode","latest-offset"); // latest-offset initialFlink CDC 里我在代码中是这样写的,为什么还是将全量数据读取了?ini....

问答 2024-03-11 来自:开发者社区

使用flink CDC的flinksql可以不传输delete的数据吗?

使用flink CDC的flinksql可以不传输delete的数据吗?或通过 WITH ('connector' 实现 ,或通过flink的配置文件,能实现吗?

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

flink cdc 3.0 整库同步数据,会导致业务数据库正常访问吗?比如被锁定,或者负载变高。

我现在使用的是flink cdc pipeline的方式,整库从mysql同步到StarRocks里面,首次全量是否会对mysql造成大量资源消耗,导致影响业务服务。

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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