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

Flink CDC只跑一个就同步挺快的,是不是哪里没配置好?自定义sink

Flink CDC只跑一个就同步挺快的,是不是哪里没配置好?自定义sink private Connection connection; @Override public void open(Configuration parameters) throws Exception { super.open(parameters); Class.forName("oracle.jdbc...

问答 2023-06-29 来自:开发者社区

大佬们,怎么让flink cdc 只关注我写的几个字段啊,其他字段变化不影响sink?我的源表我只想

大佬们,怎么让flink cdc 只关注我写的几个字段啊,其他字段变化不影响sink?我的源表我只想关注2个字段的变化,但是现在源表每个字段变化目标表都有一个upsert语句,导致sink表变化太频繁了,业务说数据不稳定

问答 2023-06-29 来自:开发者社区

请教一下Flink CDC中各位大佬们有没有遇到sink语句关键字报错?

请教一下Flink CDC中各位大佬们有没有遇到sink语句关键字报错?

问答 2023-06-29 来自:开发者社区

大佬们,我用Flink CDC做多表join,有一张源表某个字段变化很平凡,导致我的sink表变化?

大佬们,我用Flink CDC做多表join,有一张源表某个字段变化很平凡,导致我的sink表变化很频繁,但是我不关注那个表的那个字段,怎么让sink表的数据相对稳定呢?

问答 2023-06-29 来自:开发者社区

大佬们,Flink CDC中sink有什么异步方案吗?

大佬们,Flink CDC中sink有什么异步方案吗?

问答 2023-06-18 来自:开发者社区

请问,Flink CDC中如果只有一个sink的话,invoke处理的时候是不是就能保证是有序的了?

请问,Flink CDC中如果只有一个sink的话,invoke处理的时候是不是就能保证是有序的了?

问答 2023-06-18 来自:开发者社区

请问,Flink CDC中我现在需要自定义的反序列化和sink,但是目前执行的使用sink类里报?

请问,Flink CDC中我现在需要自定义的反序列化和sink,但是目前执行的使用sink类里报NotSerializableException,是有什么需要注意的吗?我已经把sink类的变量都设置成transient了

问答 2023-06-18 来自:开发者社区

问下大佬们,Flink CDC mysql到pg。sink节点busy 100%,导致source?

问下大佬们,Flink CDC mysql到pg。sink节点busy 100%,导致source也报错,有人遇到吗

问答 2023-06-18 来自:开发者社区

各位老师 Flink CDC提示成功 去sink 端查不到数据呢 是怎么回事?

各位老师 Flink CDC提示成功 去sink 端查不到数据呢 是怎么回事?

问答 2023-06-18 来自:开发者社区

请教各位老师 Flink CDC中 jdbc sink ck 时,是jar 包的事吗?老师

问题1:请教各位老师 Flink CDC中 jdbc sink ck 时 是jar 包的事吗 老师 问题2:2.4版本支持clickhouse吗

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注