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

[chesnay]

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 <ches...@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);
+       }
 }