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;