zhuzhurk commented on a change in pull request #12256:
URL: https://github.com/apache/flink/pull/12256#discussion_r436239010
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorTest.java
##########
@@ -189,7 +192,7 @@ private DefaultExecutionSlotAllocator
createExecutionSlotAllocator(InputsLocatio
return schedulingRequirements;
}
- private SlotExecutionVertexAssignment
findSlotAssignmentByExecutionVertexId(
+ static SlotExecutionVertexAssignment
findSlotAssignmentByExecutionVertexId(
Review comment:
Agreed. Added util classes in 216a75a34f2d090d726673dc272ea2801fa6eef8
and 277ee720dee5ab63dade29c7178d9e7af69a3f21
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
