Я пытаюсь понять, как работает параллелизм во Flink. Этот документ https://ci.apache.org/projects/flink/flink-docs-release-1.9/concepts/programming-model.html, кажется, предполагает, что приемник имеет параллелизм, равный 1. В моем случае я пишу в HBase в моем приемнике - означает ли это, что существует только одна задача (поток?), Которая будетписать в HBase? Разве он не получает глобальный параллелизм, установленный для приложения?
Раковина получает глобальный параллелизм. Чтобы уменьшить его на один оператор, как в этом примере, требуется явное изменение параллелизма для этого оператора.
Означает ли это, что существует только одна задача (поток), записывающая в HBase, когда параллелизм равен единице?
Да. Как правило, параллелизм - это число задач оператора, которые выполняются одновременно. По умолчанию он равен установленному вами глобальному параллелизму.