austince commented on a change in pull request #15348:
URL: https://github.com/apache/flink/pull/15348#discussion_r604406970
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java
##########
@@ -251,9 +282,8 @@ public void
testExecutionGraphGenerationWithAvailableResources() throws Exceptio
final int numAvailableSlots = 1;
- final OneShotLatch submitTaskLatch = new OneShotLatch();
- final TaskManagerGateway taskManagerGateway =
-
createWaitingForTaskSubmissionTaskManagerGateway(submitTaskLatch);
+ final SubmissionBufferingTaskManagerGateway taskManagerGateway =
+ new SubmissionBufferingTaskManagerGateway(numAvailableSlots);
Review comment:
Since I'm reverting the Parameterized bits and not running everything in
Reactive mode, I could revert these as well, but is a decent cleanup IMO.
--
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]
