You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/18 21:04:14 UTC
flink git commit: [FLINK-9045][REST][addendum] Batch
createLocalEnvironmentWithWebUI starts on 8081
Repository: flink
Updated Branches:
refs/heads/master 11509898f -> ae0b496c4
[FLINK-9045][REST][addendum] Batch createLocalEnvironmentWithWebUI starts on 8081
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ae0b496c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ae0b496c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ae0b496c
Branch: refs/heads/master
Commit: ae0b496c4d0f55a7752a0900bf32d4f1215302c2
Parents: 1150989
Author: zentol <ch...@apache.org>
Authored: Wed Apr 18 23:02:35 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Wed Apr 18 23:02:35 2018 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/client/LocalExecutor.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ae0b496c/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java b/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
index 48855be..f209b45 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
@@ -126,7 +126,9 @@ public class LocalExecutor extends PlanExecutor {
final JobExecutorService newJobExecutorService;
if (CoreOptions.NEW_MODE.equals(configuration.getString(CoreOptions.MODE))) {
- configuration.setInteger(RestOptions.REST_PORT, 0);
+ if (!configuration.contains(RestOptions.REST_PORT)) {
+ configuration.setInteger(RestOptions.REST_PORT, 0);
+ }
final MiniClusterConfiguration miniClusterConfiguration = new MiniClusterConfiguration.Builder()
.setConfiguration(configuration)