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/05/10 14:21:45 UTC
[6/9] flink git commit: [hotfix][yarn] Reduce visibility of fields.
[hotfix][yarn] Reduce visibility of fields.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90a0a910
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/90a0a910
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/90a0a910
Branch: refs/heads/master
Commit: 90a0a91079a4e271404dadee4cf4106dfd18ad89
Parents: fa11015
Author: gyao <ga...@data-artisans.com>
Authored: Fri Apr 27 15:51:38 2018 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Thu May 10 16:18:31 2018 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/yarn/YarnResourceManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/90a0a910/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
index 266c037..c498634 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
@@ -74,14 +74,14 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme
private final Map<String, String> env;
/** YARN container map. Package private for unit test purposes. */
- final ConcurrentMap<ResourceID, YarnWorkerNode> workerNodeMap;
+ private final ConcurrentMap<ResourceID, YarnWorkerNode> workerNodeMap;
/** The heartbeat interval while the resource master is waiting for containers. */
private static final int FAST_YARN_HEARTBEAT_INTERVAL_MS = 500;
/** Environment variable name of the final container id used by the YarnResourceManager.
* Container ID generation may vary across Hadoop versions. */
- static final String ENV_FLINK_CONTAINER_ID = "_FLINK_CONTAINER_ID";
+ private static final String ENV_FLINK_CONTAINER_ID = "_FLINK_CONTAINER_ID";
/** Environment variable name of the hostname given by the YARN.
* In task executor we use the hostnames given by YARN consistently throughout akka */