Как получить номер Flink taskmanager перед отправкой задания?

#apache-flink #flink-streaming Вопрос: У меня есть задание по потоку данных Flink, начатое val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(taskmanagernumber * x) // set env parallelism this line env.addSource...map...addSink... env.execute() Я хочу контролировать…