Hi, What kind of information do you need about the TaskExecutor? This is usually quite low level type of information which might change randomly, e.g. after restore. What is the original problem why you need it? Maybe, there is another solution. E.g. you can get index of local parallel subtask of your ProcessFunction: RuntimeContext.getIndexOfThisSubtask out of RuntimeContext.getNumberOfParallelSubtasks.
Best, Andrey On Mon, Apr 1, 2019 at 11:33 AM peibin wang <wangpeibin...@gmail.com> wrote: > Hi all > > I want to get the right TaskExecutor where the ProcessFunction run at. > Is there any way to get it from getRuntimeContext() . Or any other > solution?? > > > > Best wishes, >
