You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2013/10/05 18:18:11 UTC
svn commit: r1529474 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java
Author: hashutosh
Date: Sat Oct 5 16:18:11 2013
New Revision: 1529474
URL: http://svn.apache.org/r1529474
Log:
HIVE-5431 : PassthroughOutputFormat SH changes causes IllegalArgumentException (Sushanth Sowmyan via Ashutosh Chauhan)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java?rev=1529474&r1=1529473&r2=1529474&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java Sat Oct 5 16:18:11 2013
@@ -773,15 +773,18 @@ public final class PlanUtils {
"using configureTableJobProperties",e);
storageHandler.configureTableJobProperties(tableDesc, jobProperties);
}
+ if (tableDesc.getOutputFileFormatClass().getName()
+ == HivePassThroughOutputFormat.HIVE_PASSTHROUGH_OF_CLASSNAME) {
+ // get the real output format when we register this for the table
+ jobProperties.put(
+ HivePassThroughOutputFormat.HIVE_PASSTHROUGH_STORAGEHANDLER_OF_JOBCONFKEY,
+ HiveFileFormatUtils.getRealOutputFormatClassName());
+ }
}
// Job properties are only relevant for non-native tables, so
// for native tables, leave it null to avoid cluttering up
// plans.
if (!jobProperties.isEmpty()) {
- if (tableDesc.getOutputFileFormatClass().getName() == HivePassThroughOutputFormat.HIVE_PASSTHROUGH_OF_CLASSNAME) {
- // get the real output format when we register this for the table
- jobProperties.put(HivePassThroughOutputFormat.HIVE_PASSTHROUGH_STORAGEHANDLER_OF_JOBCONFKEY,HiveFileFormatUtils.getRealOutputFormatClassName());
- }
tableDesc.setJobProperties(jobProperties);
}
}