[flink] 10/13: [hotfix] Rename configuration param in constructor of (Stream)ExecutionEnv

[kkloudas]

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

kkloudas pushed a commit to branch executors-clean
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 03cb7ef4c919f6f5496689bba6edb6feb69d1a3e
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Mon Nov 18 16:40:52 2019 +0100

    [hotfix] Rename configuration param in constructor of (Stream)ExecutionEnv
---
 .../java/org/apache/flink/api/java/ExecutionEnvironment.java   |  8 ++++----
 .../streaming/api/environment/StreamExecutionEnvironment.java  | 10 ++++------
 2 files changed, 8 insertions(+), 10 deletions(-)

diff --git 
a/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java 
b/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
index d485105..6e64788 100644
--- 
a/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
+++ 
b/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
@@ -142,13 +142,13 @@ public class ExecutionEnvironment {
                this(new Configuration());
        }
 
-       protected ExecutionEnvironment(final Configuration 
executorConfiguration) {
-               this(DefaultExecutorServiceLoader.INSTANCE, 
executorConfiguration);
+       protected ExecutionEnvironment(final Configuration configuration) {
+               this(DefaultExecutorServiceLoader.INSTANCE, configuration);
        }
 
-       protected ExecutionEnvironment(final ExecutorServiceLoader 
executorServiceLoader, final Configuration executorConfiguration) {
+       protected ExecutionEnvironment(final ExecutorServiceLoader 
executorServiceLoader, final Configuration configuration) {
                this.executorServiceLoader = 
checkNotNull(executorServiceLoader);
-               this.configuration = checkNotNull(executorConfiguration);
+               this.configuration = checkNotNull(configuration);
                this.userClassloader = getClass().getClassLoader();
        }
 
diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
index 176a7ab..b8544cf 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -165,15 +165,13 @@ public class StreamExecutionEnvironment {
                this(new Configuration());
        }
 
-       public StreamExecutionEnvironment(final Configuration 
executorConfiguration) {
-               this(DefaultExecutorServiceLoader.INSTANCE, 
executorConfiguration);
+       public StreamExecutionEnvironment(final Configuration configuration) {
+               this(DefaultExecutorServiceLoader.INSTANCE, configuration);
        }
 
-       public StreamExecutionEnvironment(
-                       final ExecutorServiceLoader executorServiceLoader,
-                       final Configuration executorConfiguration) {
+       public StreamExecutionEnvironment(final ExecutorServiceLoader 
executorServiceLoader, final Configuration configuration) {
                this.executorServiceLoader = 
checkNotNull(executorServiceLoader);
-               this.configuration = checkNotNull(executorConfiguration);
+               this.configuration = checkNotNull(configuration);
                this.userClassloader = getClass().getClassLoader();
        }