hadoop-hdfs-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject svn commit: r1103987 - in /hadoop/hdfs/trunk: CHANGES.txt src/java/org/apache/hadoop/hdfs/DFSClient.java
Date Tue, 17 May 2011 02:23:51 GMT
Author: eli
Date: Tue May 17 02:23:50 2011
New Revision: 1103987

URL: http://svn.apache.org/viewvc?rev=1103987&view=rev
Log:
HDFS-1947. DFSClient should use mapreduce.task.attempt.id. Contributed by Eli Collins

Modified:
    hadoop/hdfs/trunk/CHANGES.txt
    hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/DFSClient.java

Modified: hadoop/hdfs/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hdfs/trunk/CHANGES.txt?rev=1103987&r1=1103986&r2=1103987&view=diff
==============================================================================
--- hadoop/hdfs/trunk/CHANGES.txt (original)
+++ hadoop/hdfs/trunk/CHANGES.txt Tue May 17 02:23:50 2011
@@ -811,6 +811,8 @@ Release 0.22.0 - Unreleased
     HDFS-1835. DataNode should not depend on SHA1PRNG secure random generator
     to generate a storage ID. (John Carrino via todd)
 
+    HDFS-1947. DFSClient should use mapreduce.task.attempt.id. (eli)
+
   OPTIMIZATIONS
 
     HDFS-1140. Speedup INode.getPathComponents. (Dmytro Molkov via shv)

Modified: hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/DFSClient.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/DFSClient.java?rev=1103987&r1=1103986&r2=1103987&view=diff
==============================================================================
--- hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/DFSClient.java (original)
+++ hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/DFSClient.java Tue May 17 02:23:50 2011
@@ -259,7 +259,7 @@ public class DFSClient implements FSCons
         nameNodeAddr.getHostName() + ":" + nameNodeAddr.getPort();
     this.leaserenewer = LeaseRenewer.getInstance(authority, ugi, this);
     
-    String taskId = conf.get("mapred.task.id", "NONMAPREDUCE");
+    String taskId = conf.get("mapreduce.task.attempt.id", "NONMAPREDUCE");
     this.clientName = leaserenewer.getClientName(taskId);
 
     defaultBlockSize = conf.getLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, DEFAULT_BLOCK_SIZE);



Mime
View raw message