How can I get the right TaskExecutor in ProcessFunction

[peibin wang]

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,  

[Andrey Zagrebin-3]

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 <[hidden email]> 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,