svn commit: r983848 - in /hadoop/hdfs/trunk: CHANGES.txt src/java/org/apache/hadoop/hdfs/HftpFileSystem.java

[jghoman]

Author: jghoman
Date: Tue Aug 10 00:42:15 2010
New Revision: 983848

URL: http://svn.apache.org/viewvc?rev=983848&view=rev
Log:
HDFS-1334. open in HftpFileSystem does not add delegation tokens to the url. 
Contributed by Jitendra Pandey.

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

Modified: hadoop/hdfs/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/hdfs/trunk/CHANGES.txt?rev=983848&r1=983847&r2=983848&view=diff
==============================================================================
--- hadoop/hdfs/trunk/CHANGES.txt (original)
+++ hadoop/hdfs/trunk/CHANGES.txt Tue Aug 10 00:42:15 2010
@@ -192,6 +192,9 @@ Trunk (unreleased changes)
     HDFS-1296. using delegation token over hftp for long running 
     clients (boryas)
 
+    HDFS-1334. open in HftpFileSystem does not add delegation tokens to the 
url.
+    (Jitendra Pandey via jghoman)
+
 Release 0.21.0 - Unreleased
 
   INCOMPATIBLE CHANGES

Modified: hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/HftpFileSystem.java
URL: 
http://svn.apache.org/viewvc/hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/HftpFileSystem.java?rev=983848&r1=983847&r2=983848&view=diff
==============================================================================
--- hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/HftpFileSystem.java 
(original)
+++ hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/HftpFileSystem.java Tue 
Aug 10 00:42:15 2010
@@ -291,8 +291,9 @@ public class HftpFileSystem extends File
 
   @Override
   public FSDataInputStream open(Path f, int buffersize) throws IOException {
-    URL u = getNamenodeURL("/data" + f.toUri().getPath(), 
-        "ugi=" + getUgiParameter());
+    String query = "ugi=" + getUgiParameter();
+    query = updateQuery(query);
+    URL u = getNamenodeURL("/data" + f.toUri().getPath(), query);
     return new FSDataInputStream(new ByteRangeInputStream(u));
   }