You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/02/28 12:27:33 UTC
[2/4] flink git commit: [FLINK-8787][flip6] Do not copy
flinkConfiguration in AbstractYarnClusterDescriptor
[FLINK-8787][flip6] Do not copy flinkConfiguration in AbstractYarnClusterDescriptor
This closes #5591.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/71baa278
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/71baa278
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/71baa278
Branch: refs/heads/master
Commit: 71baa2784edab8b851dabe15855a023c73b4fc1c
Parents: f89fce8
Author: gyao <ga...@data-artisans.com>
Authored: Tue Feb 27 16:58:53 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Wed Feb 28 13:27:05 2018 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/71baa278/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java b/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
index e6c36f6..6b93016 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
@@ -482,7 +482,7 @@ public abstract class AbstractYarnClusterDescriptor implements ClusterDescriptor
flinkConfiguration.setString(ClusterEntrypoint.EXECUTION_MODE, executionMode.toString());
ApplicationReport report = startAppMaster(
- new Configuration(flinkConfiguration),
+ flinkConfiguration,
yarnClusterEntrypoint,
jobGraph,
yarnClient,