pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1400539 - in /pig/branches/branch-0.10: CHANGES.txt src/org/apache/pig/impl/util/UDFContext.java
Date Sun, 21 Oct 2012 00:03:36 GMT
Author: daijy
Date: Sun Oct 21 00:03:35 2012
New Revision: 1400539

URL: http://svn.apache.org/viewvc?rev=1400539&view=rev
Log:
PIG-2940: HBaseStorage store fails in secure cluster

Modified:
    pig/branches/branch-0.10/CHANGES.txt
    pig/branches/branch-0.10/src/org/apache/pig/impl/util/UDFContext.java

Modified: pig/branches/branch-0.10/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/CHANGES.txt?rev=1400539&r1=1400538&r2=1400539&view=diff
==============================================================================
--- pig/branches/branch-0.10/CHANGES.txt (original)
+++ pig/branches/branch-0.10/CHANGES.txt Sun Oct 21 00:03:35 2012
@@ -36,6 +36,8 @@ PIG-2727: PigStorage Source tagging does
 
 BUG FIXES
 
+PIG-2940: HBaseStorage store fails in secure cluster (rohini via daijy)
+
 PIG-2821: HBaseStorage should work with secure hbase (rohini via daijy)
 
 PIG-2890: Revert PIG-2578 (dvryaboy)

Modified: pig/branches/branch-0.10/src/org/apache/pig/impl/util/UDFContext.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/src/org/apache/pig/impl/util/UDFContext.java?rev=1400539&r1=1400538&r2=1400539&view=diff
==============================================================================
--- pig/branches/branch-0.10/src/org/apache/pig/impl/util/UDFContext.java (original)
+++ pig/branches/branch-0.10/src/org/apache/pig/impl/util/UDFContext.java Sun Oct 21 00:03:35
2012
@@ -211,7 +211,11 @@ public class UDFContext {
      * @return
      */
     public boolean isFrontend() {
-    	return (this.jconf == null || jconf.get("mapred.task.id") == null);
+        // mapred.task.id is for MR1
+        // mapreduce.job.application.attempt.id is for MR2
+        return (this.jconf == null
+                || (jconf.get("mapred.task.id") == null &&
+                    jconf.get("mapreduce.job.application.attempt.id") == null));
     }
     
     /**



Mime
View raw message