[flink] branch master updated: [FLINK-22980][tests] Set parallelism on job vertex required by adaptive scheduler

[rmetzger]

This is an automated email from the ASF dual-hosted git repository.

rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 465fc66  [FLINK-22980][tests] Set parallelism on job vertex required 
by adaptive scheduler
465fc66 is described below

commit 465fc66949c010af740bb242125ce15116ac0aeb
Author: Fabian Paul <fabianp...@ververica.com>
AuthorDate: Thu Jun 17 10:39:05 2021 +0200

    [FLINK-22980][tests] Set parallelism on job vertex required by adaptive 
scheduler
---
 .../flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java       | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java
index 43f69bd..b1a01c6 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java
@@ -349,6 +349,8 @@ public class FileExecutionGraphInfoStoreTest extends 
TestLogger {
                 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);