You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by cw...@apache.org on 2012/11/09 00:12:15 UTC
svn commit: r1407312 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/BucketMapJoinContext.java
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;