You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by th...@apache.org on 2019/01/23 18:13:55 UTC
[flink] branch master updated: [FLINK-11048] Mark new
RemoteStreamEnvironment constructor PublicEvolving
This is an automated email from the ASF dual-hosted git repository.
thw 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 20fff57 [FLINK-11048] Mark new RemoteStreamEnvironment constructor PublicEvolving
20fff57 is described below
commit 20fff575465f4f2a480277bd3e8973d66a50fcd2
Author: Thomas Weise <th...@apache.org>
AuthorDate: Tue Jan 22 15:40:33 2019 -0800
[FLINK-11048] Mark new RemoteStreamEnvironment constructor PublicEvolving
---
.../apache/flink/streaming/api/environment/RemoteStreamEnvironment.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java
index 4fcb555..f9c32ee 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java
@@ -168,6 +168,7 @@ public class RemoteStreamEnvironment extends StreamExecutionEnvironment {
* @param savepointRestoreSettings
* Optional savepoint restore settings for job execution.
*/
+ @PublicEvolving
public RemoteStreamEnvironment(String host, int port, Configuration clientConfiguration, String[] jarFiles, URL[] globalClasspaths, SavepointRestoreSettings savepointRestoreSettings) {
if (!ExecutionEnvironment.areExplicitEnvironmentsAllowed()) {
throw new InvalidProgramException(