Identify the task within PartitionRequestQueue

[Chris Miller]

 

Hi all,

I just made some changes within the
flink/runtime/io/network/netty/PartitionRequestQueue.java

These changes should only be aplied to Join-Tasks. Is there a way to
figure out which Task the current PartitionRequestQueue object relates
to?

Something like:

if(this.task.getTaskInfo().getTaskNameWithSubtasks().contains("Join")){

//you are in the Join Task

}

Thanks.

Chris
 

[Zhijiang(wangzhijiang999)]

Hi Chris,

The PartitionRequestQueue is a netty handler which would be reused by multiple tasks, so actually there might be a list of tasks releated to each ParititonRequestQueue.
If you want to establish the mapping betwwen them, it might establish the mapping between subpartiiton view and task name, then you can get all the created views from PartitionRequestQueue.

Best,
Zhijiang
------------------------------------------------------------------
From:Chris Miller <[hidden email]>
Send Time:2019年1月12日(星期六) 16:13
To:dev <[hidden email]>
Subject:Identify the task within PartitionRequestQueue



Hi all,

I just made some changes within the
flink/runtime/io/network/netty/PartitionRequestQueue.java

These changes should only be aplied to Join-Tasks. Is there a way to
figure out which Task the current PartitionRequestQueue object relates
to?

Something like:

if(this.task.getTaskInfo().getTaskNameWithSubtasks().contains("Join")){

//you are in the Join Task

}

Thanks.

Chris