You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2020/06/22 13:59:24 UTC
[flink] 02/02: [hotfix] Annotate the
DefaultClusterClientServiceLoader as internal
This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1ad47e3ebe5d0de739a58966992a3b45c34bcb32
Author: Kostas Kloudas <kk...@gmail.com>
AuthorDate: Fri Jun 19 14:12:05 2020 +0200
[hotfix] Annotate the DefaultClusterClientServiceLoader as internal
---
.../flink/client/deployment/DefaultClusterClientServiceLoader.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java b/flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java
index ec56abe..0ba773b 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java
@@ -18,6 +18,7 @@
package org.apache.flink.client.deployment;
+import org.apache.flink.annotation.Internal;
import org.apache.flink.configuration.Configuration;
import org.slf4j.Logger;
@@ -34,6 +35,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
/**
* A service provider for {@link ClusterClientFactory cluster client factories}.
*/
+@Internal
public class DefaultClusterClientServiceLoader implements ClusterClientServiceLoader {
private static final Logger LOG = LoggerFactory.getLogger(DefaultClusterClientServiceLoader.class);