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
