[flink] branch release-1.10 updated: [hotfix][streaming] Fix API incompatibility

[ch...@apache.org]

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

chesnay pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.10 by this push:
     new 6379f2a  [hotfix][streaming] Fix API incompatibility
6379f2a is described below

commit 6379f2a05da03ad59a04e32dbe0fbd4379df0bc4
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu Dec 12 19:45:13 2019 +0100

    [hotfix][streaming] Fix API incompatibility
---
 .../flink/streaming/api/environment/LocalStreamEnvironment.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java
index f7fee91..99e941b 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java
@@ -19,9 +19,11 @@ package org.apache.flink.streaming.api.environment;
 
 import org.apache.flink.annotation.Public;
 import org.apache.flink.api.common.InvalidProgramException;
+import org.apache.flink.api.common.JobExecutionResult;
 import org.apache.flink.api.java.ExecutionEnvironment;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.DeploymentOptions;
+import org.apache.flink.streaming.api.graph.StreamGraph;
 
 import javax.annotation.Nonnull;
 
@@ -66,4 +68,9 @@ public class LocalStreamEnvironment extends StreamExecutionEnvironment {
 		effectiveConfiguration.set(DeploymentOptions.ATTACHED, true);
 		return effectiveConfiguration;
 	}
+
+	@Override
+	public JobExecutionResult execute(StreamGraph streamGraph) throws Exception {
+		return super.execute(streamGraph);
+	}
 }