Я использую flink run -m yarn-cluster -c my.Main
для подачи заявки в кластер пряжи , код содержит несколько операторов, которые запускают вычисления (позвольте мне назвать это action operator
) , как collect
и другие
Мой вопросесть: я бы спросил, будет ли один оператор действия создавать идентификатор задания, то есть одно приложение может иметь много идентификаторов задания;или все операторы действий в приложении будут иметь только один идентификатор задания?
Насколько я понимаю, у всего приложения есть только один JobGraph, поэтому существует только один идентификатор задания (полученный от JobGragh.getJobID)