[flink] branch master updated: [hotfix][datastream] Add missing Internal annotations for OperatorCoordinator class

[pnowojski]

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

pnowojski 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 dbe23f1  [hotfix][datastream] Add missing Internal annotations for 
OperatorCoordinator class
dbe23f1 is described below

commit dbe23f13cdd6ae873f3d244771c9351aa67ded8c
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
AuthorDate: Thu Oct 7 11:56:45 2021 +0200

    [hotfix][datastream] Add missing Internal annotations for 
OperatorCoordinator class
    
    For now we don't want to expose the coordinators, just things that use a
    coordinator, like the SourceEnumerator.
---
 .../flink/runtime/operators/coordination/OperatorCoordinator.java       | 2 ++
 .../flink/streaming/api/operators/CoordinatedOperatorFactory.java       | 2 ++
 2 files changed, 4 insertions(+)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
index 2e2869f..14d6381 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.runtime.operators.coordination;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.state.CheckpointListener;
 import org.apache.flink.runtime.executiongraph.ExecutionAttemptID;
 import org.apache.flink.runtime.jobgraph.OperatorID;
@@ -70,6 +71,7 @@ import java.util.concurrent.CompletableFuture;
  *       methods, the task are scheduled and deployed.
  * </ol>
  */
+@Internal
 public interface OperatorCoordinator extends CheckpointListener, AutoCloseable 
{
 
     /**
diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/CoordinatedOperatorFactory.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/CoordinatedOperatorFactory.java
index de1a57f..7afe4ff 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/CoordinatedOperatorFactory.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/CoordinatedOperatorFactory.java
@@ -18,6 +18,7 @@ limitations under the License.
 
 package org.apache.flink.streaming.api.operators;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.runtime.jobgraph.OperatorID;
 import org.apache.flink.runtime.operators.coordination.OperatorCoordinator;
 
@@ -25,6 +26,7 @@ import 
org.apache.flink.runtime.operators.coordination.OperatorCoordinator;
  * A factory class for the {@link StreamOperator}s implementing {@link
  * org.apache.flink.runtime.operators.coordination.OperatorEventHandler}.
  */
+@Internal
 public interface CoordinatedOperatorFactory<OUT> extends 
StreamOperatorFactory<OUT> {
 
     /**