问答 2023-04-26 来自:开发者社区

请教各位一个问题,我使用Flink CDC同步MYSQL数据到Elasticsearch,当我停掉F

请教各位一个问题,我使用Flink CDC同步MYSQL数据到Elasticsearch,当我停掉Flink后,在MYSQL中删除数据,再启动Flink CDC job,这时候Elasticsearch中存在脏数据,没有删除掉MYSQL中已经删除了的数据,这种情况有遇到的吗?

问答 2023-04-26 来自:开发者社区

请教一下大佬们,我用FLink CDC 同步MySQL数据 ,然后进行聚合通过自定义一个MQTT s

请教一下大佬们,我用FLink CDC 同步MySQL数据 ,然后进行聚合通过自定义一个MQTT sink推出去?结果自定义的sink flink死活加载不出了 找不到 但是我一直感觉自己代码没有问题,有经验的大佬帮忙给点意见

问答 2023-04-26 来自:开发者社区

请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄

请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄

问答 2023-04-26 来自:开发者社区

各位大佬, flink cdc从kafka同步数据到 hudi , 写入效率很低,目前只能达到每分钟

各位大佬, flink cdc从kafka同步数据到 hudi , 写入效率很低,目前只能达到每分钟10W左右 ,使用的是MOR。 有没有大佬指导一下

问答 2023-04-26 来自:开发者社区

flink cdc 同步mysql8.0数据库 初始化全量数据同步成功 变更数据 获取出现空指针异

flink cdc 同步mysql8.0数据库 初始化全量数据同步成功 变更数据 获取出现空指针异常 有大佬遇到过么

问答 2023-04-26 来自:开发者社区

请教个问题,flink cdc同步mysql数据到iceberg。任务运行一段时间后,表的结构改了(

请教个问题,flink cdc同步mysql数据到iceberg。任务运行一段时间后,表的结构改了(比如新增了2个字段),如果人工手动把ddl也同步到iceberg了,这时候任务要怎么处理才能同步数据?

问答 2023-04-26 来自:开发者社区

我现在可以通过flink cdc实时的同步ddl到iceberg,但是同步完后再同步数据就报错怎么办

我现在可以通过flink cdc实时的同步ddl到iceberg,但是同步完后再同步数据就报错怎么办?我debug后发现它没进SinkUpsertMaterializer

问答 2023-04-25 来自:开发者社区

Flink cdc可以同步普罗米修斯的数据吗

Flink cdc可以同步普罗米修斯的数据吗

问答 2023-04-25 来自:开发者社区

大佬,Flink CDC 这个是需要设置失败次数吗,在哪里,设置同步了5万多条数据,很不稳定,延迟特

大佬,Flink CDC 这个是需要设置失败次数吗,在哪里,设置同步了5万多条数据,很不稳定,延迟特别严重

问答 2023-04-19 来自:开发者社区

大佬,flink cdc sql同步数据,是不是随时都可以上线。因为每次上线后都是从头启动的,不知道

大佬,flink cdc sql同步数据,是不是随时都可以上线。因为每次上线后都是从头启动的,不知道会不会影响报表?

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

产品推荐

实时计算 Flink

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

+关注