首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Flink Sink并行= 1?

Flink Sink并行= 1?
EN

Stack Overflow用户
提问于 2019-10-04 13:10:05
回答 2查看 529关注 0票数 1

我正在尝试理解Flink中的并行性是如何工作的。这个文档https://ci.apache.org/projects/flink/flink-docs-release-1.9/concepts/programming-model.html似乎表明接收器的并行度等于1。在我的例子中,我在接收器中写入HBase -这是否意味着只有一个任务(线程?)哪个将写入HBase?它是否没有获得为应用程序设置的全局并行度?

EN

回答 2

Stack Overflow用户

发布于 2019-10-04 13:58:16

接收器获得全局并行度。要减少一个运算符上的并行度,需要显式更改该运算符上的并行度。

票数 3
EN

Stack Overflow用户

发布于 2019-10-04 13:34:58

这是否意味着当并行度等于1时,只有一个任务(线程)写入HBase?

是。通常,并行度是同时运行的操作员任务的数量。默认情况下,它等于您设置的全局并行度。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/58230259

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档