You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hive.apache.org by da...@apache.org on 2014/11/08 00:00:05 UTC

svn commit: r1637478 - /hive/branches/branch-0.14/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java

Author: daijy
Date: Fri Nov  7 23:00:05 2014
New Revision: 1637478

URL: http://svn.apache.org/r1637478
Log:
HIVE-8484: HCatalog throws an exception if Pig job is of type 'fetch' (Lorand Bendig via Daniel Dai)

Modified:
    hive/branches/branch-0.14/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java

Modified: hive/branches/branch-0.14/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java
URL: http://svn.apache.org/viewvc/hive/branches/branch-0.14/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java?rev=1637478&r1=1637477&r2=1637478&view=diff
==============================================================================
--- hive/branches/branch-0.14/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java (original)
+++ hive/branches/branch-0.14/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java Fri Nov  7 23:00:05 2014
@@ -83,8 +83,9 @@ public class HCatUtil {
   private static volatile HiveClientCache hiveClientCache;
 
   public static boolean checkJobContextIfRunningFromBackend(JobContext j) {
-    if (j.getConfiguration().get("mapred.task.id", "").equals("") &&
-        !("true".equals(j.getConfiguration().get("pig.illustrating")))) {
+    if (j.getConfiguration().get("pig.job.converted.fetch", "").equals("") &&
+          j.getConfiguration().get("mapred.task.id", "").equals("") &&
+          !("true".equals(j.getConfiguration().get("pig.illustrating")))) {
       return false;
     }
     return true;