У одного приложения flink только один идентификатор работы - PullRequest
0 голосов
/ 11 февраля 2019

Я использую flink run -m yarn-cluster -c my.Main для подачи заявки в кластер пряжи , код содержит несколько операторов, которые запускают вычисления (позвольте мне назвать это action operator) , как collect и другие

Мой вопросесть: я бы спросил, будет ли один оператор действия создавать идентификатор задания, то есть одно приложение может иметь много идентификаторов задания;или все операторы действий в приложении будут иметь только один идентификатор задания?

Насколько я понимаю, у всего приложения есть только один JobGraph, поэтому существует только один идентификатор задания (полученный от JobGragh.getJobID)

...