[FLINK-22980][tests] Set parallelism on job vertex required by adapti…

…ve scheduler
derekm · Jun 18, 2021 · 465fc66 · 465fc66
1 parent c056a95
commit 465fc66
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...me/src/test/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java b/...me/src/test/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java
@@ -349,6 +349,8 @@ public void testPutSuspendedJobOnClusterShutdown() throws Exception {
  new PersistingMiniCluster(new MiniClusterConfiguration.Builder().build())) {
  miniCluster.start();
  final JobVertex vertex = new JobVertex("blockingVertex");
+ // The adaptive scheduler expects that every vertex has a configured parallelism
+ vertex.setParallelism(1);
  vertex.setInvokableClass(SignallingBlockingNoOpInvokable.class);
  final JobGraph jobGraph = JobGraphTestUtils.streamingJobGraph(vertex);
  miniCluster.submitJob(jobGraph);