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 2019/11/18 21:00:42 UTC
[flink] 10/13: [hotfix] Rename configuration param in constructor
of (Stream)ExecutionEnv
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 <kk...@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();
}