hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From c..@apache.org
Subject svn commit: r1407312 - /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/BucketMapJoinContext.java
Date Thu, 08 Nov 2012 23:12:15 GMT
Author: cws
Date: Thu Nov  8 23:12:15 2012
New Revision: 1407312

URL: http://svn.apache.org/viewvc?rev=1407312&view=rev
Log:
HIVE-3651. bucketmapjoin?.q tests fail with hadoop 0.23 (Prasad Mujumdar via cws)

Modified:
    hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/BucketMapJoinContext.java

Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/BucketMapJoinContext.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/BucketMapJoinContext.java?rev=1407312&r1=1407311&r2=1407312&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/BucketMapJoinContext.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/BucketMapJoinContext.java Thu Nov
 8 23:12:15 2012
@@ -18,6 +18,7 @@
 package org.apache.hadoop.hive.ql.plan;
 
 import java.io.Serializable;
+import java.net.URI;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.LinkedHashMap;
@@ -199,7 +200,7 @@ public class BucketMapJoinContext implem
   private String prependPartSpec(String inputPath, String fileName) {
     Map<String, String> mapping = inputToPartSpecMapping == null ?
         inputToPartSpecMapping = revert(bigTablePartSpecToFileMapping) : inputToPartSpecMapping;
-    String partSpec = mapping.get(inputPath);
+    String partSpec = mapping.get(URI.create(inputPath).getPath());
     return partSpec == null || partSpec.isEmpty() ? fileName :
       "(" + FileUtils.escapePathName(partSpec) + ")" + fileName;
   }
@@ -210,7 +211,7 @@ public class BucketMapJoinContext implem
     for (Map.Entry<String, List<String>> entry : mapping.entrySet()) {
       String partSpec = entry.getKey();
       for (String file : entry.getValue()) {
-        converted.put(file, partSpec);
+        converted.put(URI.create(file).getPath(), partSpec);
       }
     }
     return converted;



Mime
View raw message