[flink] branch master updated: [FLINK-31401][streaming][tests] Make parallelism assumption explicit in StreamingJobGraphGeneratorTest

[mbalassi]

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

mbalassi 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 eb83d854629 [FLINK-31401][streaming][tests] Make parallelism 
assumption explicit in StreamingJobGraphGeneratorTest
eb83d854629 is described below

commit eb83d854629c676becdce50ce25eb543b8b2e28a
Author: Marton Balassi <mar...@apple.com>
AuthorDate: Fri Mar 10 16:32:41 2023 +0100

    [FLINK-31401][streaming][tests] Make parallelism assumption explicit in 
StreamingJobGraphGeneratorTest
---
 .../flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
index a58a52dc536..8a6d2c9f582 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
@@ -259,6 +259,9 @@ class StreamingJobGraphGeneratorTest {
     @Test
     public void testTransformationSetParallelism() {
         StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
+        /* The default parallelism of the environment (that is inherited by 
the source)
+        and the parallelism of the map operator needs to be different for this 
test */
+        env.setParallelism(4);
         env.fromSequence(1L, 3L).map(i -> 
i).setParallelism(10).print().setParallelism(20);
         StreamGraph streamGraph = env.getStreamGraph();