pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1604687 - in /pig/trunk: CHANGES.txt contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/IndexedStorage.java
Date Mon, 23 Jun 2014 03:10:38 GMT
Author: daijy
Date: Mon Jun 23 03:10:37 2014
New Revision: 1604687

URL: http://svn.apache.org/r1604687
Log:
PIG-4033: Fix MergeSparseJoin e2e tests on tez

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/IndexedStorage.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1604687&r1=1604686&r2=1604687&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Mon Jun 23 03:10:37 2014
@@ -40,6 +40,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4033: Fix MergeSparseJoin e2e tests on tez (daijy)
+
 PIG-3478: Make StreamingUDF work for Hadoop 2 (lbendig via daijy)
 
 PIG-4032: BloomFilter fails with s3 path in Hadoop 2.4 (cheolsoo)

Modified: pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/IndexedStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/IndexedStorage.java?rev=1604687&r1=1604686&r2=1604687&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/IndexedStorage.java
(original)
+++ pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/IndexedStorage.java
Mon Jun 23 03:10:37 2014
@@ -279,7 +279,7 @@ public class IndexedStorage extends PigS
 	public void initialize(Configuration conf) throws IOException {
 		try {
 			InputFormat inputFormat = this.getInputFormat();
-			TaskAttemptID id = TaskAttemptID.forName(conf.get("mapred.task.id"));
+			TaskAttemptID id = HadoopShims.getNewTaskAttemptID();
 			
 			if (System.getenv("HADOOP_TOKEN_FILE_LOCATION") != null) {
 		                conf.set("mapreduce.job.credentials.binary", System.getenv("HADOOP_TOKEN_FILE_LOCATION"));



Mime
View raw message