This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6c4c6c89fcd66d87a89414f0b6bb2a1d308e13a4 Author: Chesnay Schepler <[email protected]> AuthorDate: Tue Jun 14 13:46:53 2022 +0200 [hotfix][tests] Remove magic number --- .../flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java index 4d8db038d0a..e454f2f136a 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java @@ -1040,7 +1040,6 @@ public class AdaptiveSchedulerTest extends TestLogger { Consumer<AdaptiveSchedulerBuilder> setupScheduler, Consumer<JobGraph> setupJobGraph) throws Exception { - final int numAvailableSlots = 4; final JobGraph jobGraph = createJobGraph(); setupJobGraph.accept(jobGraph); RunFailedJobListener listener = new RunFailedJobListener(); @@ -1070,7 +1069,7 @@ public class AdaptiveSchedulerTest extends TestLogger { final AdaptiveScheduler scheduler = builder.build(EXECUTOR_RESOURCE.getExecutor()); final SubmissionBufferingTaskManagerGateway taskManagerGateway = - new SubmissionBufferingTaskManagerGateway(numAvailableSlots); + new SubmissionBufferingTaskManagerGateway(PARALLELISM); taskManagerGateway.setCancelConsumer(cancelledTasks::add); singleThreadMainThreadExecutor.execute( @@ -1080,7 +1079,7 @@ public class AdaptiveSchedulerTest extends TestLogger { declarativeSlotPool, createSlotOffersForResourceRequirements( ResourceCounter.withResource( - ResourceProfile.UNKNOWN, numAvailableSlots)), + ResourceProfile.UNKNOWN, PARALLELISM)), taskManagerGateway); }); listener.waitForRunning();
