问答 2023-05-01 来自:开发者社区

flink cdc 能支持starrocks的source吗,之前试过source只能读取历史数据,

flink cdc 能支持starrocks的source吗,之前试过source只能读取历史数据,读完历史数据任务就自己停了,版本是1.19,是的,starrocks 2.1版本支持source了

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

大佬们,怎么可以让Flink CDC 这种日志数据不打印? 设置了日志级别,没生效 ?

大佬们,怎么可以让Flink CDC 这种日志数据不打印? 设置了日志级别,没生效 ?

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

请问,flink cdc 全量同步 不加锁,如果要同步binlog之前的数据的话,是通过select

请问,flink cdc 全量同步 不加锁,如果要同步binlog之前的数据的话,是通过select 查表获取全量数据的吗?另外: 在同步全量数据的同时,如果数据库还有更新,那么是如何解决的?

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

Flink CDC 中sink到es没有指定主键,是不是每次都会新增数据?

Flink CDC 中sink到es没有指定主键,是不是每次都会新增数据?

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

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者si

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者sink到Redis?

问答 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有什么机制保证数据不丢吗?如果丢了几条怎么恢复?

请问同步数据过程中,或者说flink cdc有什么机制保证数据不丢吗?如果丢了几条怎么恢复?

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

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

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

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

产品推荐

实时计算 Flink

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

+关注