У меня есть требование, которое необходимо выполнить в моем приложении flink. вот мои коды:
for (String key: keys ) {
inputstream.addSink(new MySinkFunction(key)).setParallelism(1)
}
и действительно, я вижу в своем веб-интерфейсе flink граф форка, и приложение работает хорошо. У меня есть несколько вопросов по этому поводу.
- Независимо от того, сколько ключей у меня в моих приложениях, в диспетчере задач будет выбран только один слот. Я понимаю, что если у меня есть два приемника, то будут взяты два слота. ?
- Если они используют только один слот, значит ли это, что все мои приемники будут обрабатываться в последовательном режиме?
Кстати, у моего кластера есть только один TaskManager.
Вот мой слот TaskManager взят.
Вот мои задачи.
