Re: How can I get the right TaskExecutor in ProcessFunction

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

How can I get the right TaskExecutor in ProcessFunction

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,