[flink] 01/02: [hotfix][API / DataStream] Make remaining tests methods package private.

[gu...@apache.org]

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

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

commit 0997037598f834eaaade38a1945d60b81947e535
Author: Eric Xiao <er...@shopify.com>
AuthorDate: Wed Apr 26 22:48:12 2023 -0400

    [hotfix][API / DataStream] Make remaining tests methods package private.
---
 .../flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 8a6d2c9f582..cf09d70e236 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
@@ -257,7 +257,7 @@ class StreamingJobGraphGeneratorTest {
     }
 
     @Test
-    public void testTransformationSetParallelism() {
+    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 */
@@ -284,7 +284,7 @@ class StreamingJobGraphGeneratorTest {
     }
 
     @Test
-    public void testChainNodeSetParallelism() {
+    void testChainNodeSetParallelism() {
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
         env.fromSequence(1L, 3L).map(value -> value).print().setParallelism(env.getParallelism());
         StreamGraph streamGraph = env.getStreamGraph();
@@ -306,7 +306,7 @@ class StreamingJobGraphGeneratorTest {
     }
 
     @Test
-    public void testChainedSourcesSetParallelism() {
+    void testChainedSourcesSetParallelism() {
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
         MultipleInputTransformation<Long> transform =
                 new MultipleInputTransformation<>(
@@ -350,7 +350,7 @@ class StreamingJobGraphGeneratorTest {
     }
 
     @Test
-    public void testDynamicGraphVertexParallelism() {
+    void testDynamicGraphVertexParallelism() {
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
         int defaultParallelism = 20;
         env.setParallelism(defaultParallelism);