Flink Sink 并行度 = 1？

Question

我试图了解 Flink 中的并行性是如何工作的。该文档https://ci.apache.org/projects/flink/flink-docs-release-1.9/concepts/programming-model.html似乎表明接收器的并行度等于1。就我而言，我是在我的接收器中写入 HBase - 这是否意味着只有一个任务（线程？）将写入 HBase？它没有为应用程序设置全局并行度吗？

Answer 1

接收器获得全局并行性。要减少一个运算符的并行性（如该示例所示），需要显式更改该运算符的并行性。