YARN-2794. Fixed log messages about distributing system-credentials. Contributed by Jian He.

hadoop-yarn-project/CHANGES.txt

@@ -949,6 +949,9 @@ Release 2.6.0 - 2014-11-15
     YARN-2843. Fixed NodeLabelsManager to trim inputs for hosts and labels so
     as to make them work correctly. (Wangda Tan via vinodkv)
 
+    YARN-2794. Fixed log messages about distributing system-credentials. (Jian He via
+    zjshen)
+
 Release 2.5.2 - 2014-11-10
 
   INCOMPATIBLE CHANGES

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.java

@@ -317,7 +317,7 @@ public static class NMContext implements Context {
     protected final ConcurrentMap<ApplicationId, Application> applications =
         new ConcurrentHashMap<ApplicationId, Application>();
 
-    private Map<ApplicationId, Credentials> systemCredentials =
+    private volatile Map<ApplicationId, Credentials> systemCredentials =
         new HashMap<ApplicationId, Credentials>();
 
     protected final ConcurrentMap<ContainerId, Container> containers =

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeStatusUpdaterImpl.java

@@ -552,7 +552,10 @@ private static Map<ApplicationId, Credentials> parseCredentials(
       map.put(entry.getKey(), credentials);
     }
     if (LOG.isDebugEnabled()) {
-      LOG.debug("Retrieved credentials form RM: " + map);
+      for (Map.Entry<ApplicationId, Credentials> entry : map.entrySet()) {
+        LOG.debug("Retrieved credentials form RM for " + entry.getKey() + ": "
+            + entry.getValue().getAllTokens());
+      }
     }
     return map;
   }

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/ResourceLocalizationService.java

@@ -1122,9 +1122,9 @@ private Credentials getSystemCredentialsSentFromRM(
       if (systemCredentials == null) {
         return null;
       }
-      for (Token<?> token : systemCredentials.getAllTokens()) {
+      if (LOG.isDebugEnabled()) {
-        LOG.info("Adding new framework-token for " + appId
+        LOG.debug("Adding new framework-token for " + appId
-            + " for localization: " + token);
+            + " for localization: " + systemCredentials.getAllTokens());
       }
       return systemCredentials;
     }

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/logaggregation/AppLogAggregatorImpl.java

@@ -202,9 +202,10 @@ private void uploadLogsForContainers() {
       Credentials systemCredentials =
           context.getSystemCredentialsForApps().get(appId);
       if (systemCredentials != null) {
-        for (Token<?> token : systemCredentials.getAllTokens()) {
+        if (LOG.isDebugEnabled()) {
-          LOG.info("Adding new framework-token for " + appId
+          LOG.debug("Adding new framework-token for " + appId
-              + " for log-aggregation: " + token + " user=" + userUgi);
+              + " for log-aggregation: " + systemCredentials.getAllTokens()
+              + "; userUgi=" + userUgi);
         }
         // this will replace old token
         userUgi.addCredentials(systemCredentials);