You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by sz...@apache.org on 2011/07/19 16:43:47 UTC

svn commit: r1148367 - in /hadoop/common/trunk/mapreduce: CHANGES.txt src/java/org/apache/hadoop/mapreduce/JobSubmitter.java

Author: szetszwo
Date: Tue Jul 19 14:43:45 2011
New Revision: 1148367

URL: http://svn.apache.org/viewvc?rev=1148367&view=rev
Log:
MAPREDUCE-2710. Update JobSubmitter.printTokens(..) for HDFS-2161.

Modified:
    hadoop/common/trunk/mapreduce/CHANGES.txt
    hadoop/common/trunk/mapreduce/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java

Modified: hadoop/common/trunk/mapreduce/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/mapreduce/CHANGES.txt?rev=1148367&r1=1148366&r2=1148367&view=diff
==============================================================================
--- hadoop/common/trunk/mapreduce/CHANGES.txt (original)
+++ hadoop/common/trunk/mapreduce/CHANGES.txt Tue Jul 19 14:43:45 2011
@@ -341,6 +341,9 @@ Trunk (unreleased changes)
 
     MAPREDUCE-2670. Fixing spelling mistake in FairSchedulerServlet.java. (eli)
 
+    MAPREDUCE-2710. Update JobSubmitter.printTokens(..) for HDFS-2161.
+    (szetszwo)
+
 Release 0.22.0 - Unreleased
 
   INCOMPATIBLE CHANGES

Modified: hadoop/common/trunk/mapreduce/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/mapreduce/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java?rev=1148367&r1=1148366&r2=1148367&view=diff
==============================================================================
--- hadoop/common/trunk/mapreduce/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java (original)
+++ hadoop/common/trunk/mapreduce/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java Tue Jul 19 14:43:45 2011
@@ -419,9 +419,6 @@ class JobSubmitter {
     }
   }
   
-
-  
-  @SuppressWarnings("unchecked")
   private void printTokens(JobID jobId,
       Credentials credentials) throws IOException {
     if (LOG.isDebugEnabled()) {
@@ -429,7 +426,7 @@ class JobSubmitter {
       for(Token<?> token: credentials.getAllTokens()) {
         if (token.getKind().toString().equals("HDFS_DELEGATION_TOKEN")) {
           LOG.debug("Submitting with " +
-              DFSClient.stringifyToken((Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier>) token));
+              org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier.stringifyToken(token));
         }
       }
     }