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 <c...@34s.de>
Send Time:2019年1月12日(星期六) 16:13
To:dev <dev@flink.apache.org>
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
