pyflink.datastream.functions.RuntimeContext.get_task_name_with_subtasks

abstract RuntimeContext.get_task_name_with_subtasks() → str

Returns the name of the task, appended with the subtask indicator, such as “MyTask (3/6)”, where 3 would be (get_index_of_this_subtask() + 1), and 6 would be get_number_of_parallel_subtasks().