我正在尝试理解Flink中的并行性是如何工作的。这个文档https://ci.apache.org/projects/flink/flink-docs-release-1.9/concepts/programming-model.html似乎表明接收器的并行度等于1。在我的例子中,我在接收器中写入HBase -这是否意味着只有一个任务(线程?)哪个将写入HBase?它是否没有获得为应用程序设置的全局并行度?
发布于 2019-10-04 13:58:16
接收器获得全局并行度。要减少一个运算符上的并行度,需要显式更改该运算符上的并行度。
发布于 2019-10-04 13:34:58
这是否意味着当并行度等于1时,只有一个任务(线程)写入HBase?
是。通常,并行度是同时运行的操作员任务的数量。默认情况下,它等于您设置的全局并行度。
https://stackoverflow.com/questions/58230259
复制相似问题