文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之sink多个并行度写入rabbit mq会导致顺序性问题吗

问题一:Flink中keyby以后是按照每个key值分别开窗吧?不同key值的窗口是互不影响的对吗? Flink中keyby以后是按照每个key值分别开窗吧?不同key值的窗口是互不影响的对吗? 参考答案: 按照每个key值分别开窗 是Session窗口 , 关于本问题的更多回答可点击进行查看: https://de...

实时计算 Flink版产品使用问题之sink多个并行度写入rabbit mq会导致顺序性问题吗
问答 2024-05-01 来自:开发者社区

Flink CDC里sink开启多个并行度,你是怎么保证binlog的顺序的?

Flink CDC里sink开启多个并行度,你是怎么保证binlog的顺序的?

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

Flink CDC里如果sink的并行度是2,其中一个sink失败了怎么保证extract ?

Flink CDC中两阶段提交是指某个sink里还是所有sink一起成功才成功,否则所有sink一起回滚吗?

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

Flink CDC里如果sink的并行度是2,其中一个sink失败了,怎么保证啊?

Flink CDC里如果sink的并行度是2,其中一个sink失败了,怎么保证extract once?

问答 2024-04-23 来自:开发者社区

Flink中sink多个并行度写入rabbit mq会导致顺序性问题吗?

Flink中sink多个并行度写入rabbit mq会导致顺序性问题吗?

问答 2024-04-22 来自:开发者社区

Flink CDC里sink多个并行度写入mq会导致顺序性问题吗?

Flink CDC里sink多个并行度写入mq会导致顺序性问题吗?

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

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,可以做到这个效果不?

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位或者其他特性分发到其他taskmanager了吗?

问答 2024-02-25 来自:开发者社区

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位分发 了吗?

Flink CDC3.0增量读取source时候,是自动根据库表了么,有没有issue或者其他介绍呀?

文章 2024-01-28 来自:开发者社区

Flink CDC 中,Sink: clean_commits 步骤的并行度

Flink CDC 中,Sink: clean_commits 步骤的并行度是由 Hudi 控制台配置决定的。您可以通过以下方式修改 Hudi 控制台的配置: 打开 Hudi 控制台,找到 "hive-site.xml" 文件。在文件中添加以下配置项: <property> <name>hoodi...

问答 2024-01-17 来自:开发者社区

flink web ui里面为啥Sink: clean_commits 这个步骤并行度是1?

我通过oracle的connector往hudi插入数据,flink web ui里面为啥Sink: clean_commits 这个步骤并行度是1,我设置的默认并行度是5,但是它改变不了?

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

产品推荐

阿里云实时计算Flink

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

+关注