我试图理解 Flink 中的并行性是如何工作的。此文档 https://ci.apache.org/projects/flink/flink-docs-release-1.9/concepts/programming-model.html 似乎表明接收器的并行度等于 1。就我而言,我正在接收器中写入HBase - 这是否意味着只有一个任务(线程?(将写入HBase?它没有为应用程序设置全局并行度吗?
接收器获得全局并行度。若要在一个运算符上减少它(如该示例所示(,需要显式更改该运算符上的并行度。
这是否意味着当并行度等于 1 时,只有一个任务(线程(写入 HBase?
是的。通常,并行度是同时运行的操作员任务的数量。默认情况下,它等于您设置的全局并行度。