[flink] 04/04: [FLINK-23402][streaming-java] Mark GlobalStreamExchangeMode as @Internal

[twalthr]

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

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

commit 313718466d15b473bd5bf1dcf0d9d988e0fd5979
Author: Timo Walther <twal...@apache.org>
AuthorDate: Mon Jul 19 16:20:03 2021 +0200

    [FLINK-23402][streaming-java] Mark GlobalStreamExchangeMode as @Internal
    
    This closes #16536.
---
 .../org/apache/flink/streaming/api/graph/GlobalStreamExchangeMode.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/GlobalStreamExchangeMode.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/GlobalStreamExchangeMode.java
index 2befa4b..ee783e3 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/GlobalStreamExchangeMode.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/GlobalStreamExchangeMode.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.streaming.api.graph;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.runtime.io.network.partition.ResultPartitionType;
 import org.apache.flink.streaming.api.transformations.StreamExchangeMode;
 import org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner;
@@ -27,6 +28,7 @@ import 
org.apache.flink.streaming.runtime.partitioner.RescalePartitioner;
  * This mode decides the default {@link ResultPartitionType} of job edges. 
Note that this only
  * affects job edges which are {@link StreamExchangeMode#UNDEFINED}.
  */
+@Internal
 public enum GlobalStreamExchangeMode {
     /** Set all job edges to be {@link ResultPartitionType#BLOCKING}. */
     ALL_EDGES_BLOCKING,