diff --git a/hcatalog/core/src/main/java/org/apache/hcatalog/common/HCatUtil.java b/hcatalog/core/src/main/java/org/apache/hcatalog/common/HCatUtil.java index 55ae9eb..15433e3 100644 --- a/hcatalog/core/src/main/java/org/apache/hcatalog/common/HCatUtil.java +++ b/hcatalog/core/src/main/java/org/apache/hcatalog/common/HCatUtil.java @@ -450,10 +450,10 @@ public static HCatStorageHandler getStorageHandler(Configuration conf, public static Map getInputJobProperties(HCatStorageHandler storageHandler, InputJobInfo inputJobInfo) { - Properties props = inputJobInfo.getTableInfo().getStorerInfo().getProperties(); - props.put(serdeConstants.SERIALIZATION_LIB,storageHandler.getSerDeClass().getName()); - TableDesc tableDesc = new TableDesc(storageHandler.getInputFormatClass(), - storageHandler.getOutputFormatClass(),props); + Properties props = inputJobInfo.getTableInfo().getStorerInfo().getProperties(); + props.put(serdeConstants.SERIALIZATION_LIB,storageHandler.getSerDeClass().getName()); + TableDesc tableDesc = new TableDesc(storageHandler.getInputFormatClass(), + storageHandler.getOutputFormatClass(),props); if (tableDesc.getJobProperties() == null) { tableDesc.setJobProperties(new HashMap()); } diff --git a/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java b/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java index e4de862..2f74cf1 100644 --- a/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java +++ b/hcatalog/core/src/main/java/org/apache/hive/hcatalog/common/HCatUtil.java @@ -483,9 +483,9 @@ public static HiveStorageHandler getStorageHandler(Configuration conf, OutputJobInfo outputJobInfo) { //TODO replace IgnoreKeyTextOutputFormat with a //HiveOutputFormatWrapper in StorageHandler - Properties props = outputJobInfo.getTableInfo().getStorerInfo().getProperties(); - props.put(serdeConstants.SERIALIZATION_LIB,storageHandler.getSerDeClass().getName()); - TableDesc tableDesc = new TableDesc(storageHandler.getInputFormatClass(), + Properties props = outputJobInfo.getTableInfo().getStorerInfo().getProperties(); + props.put(serdeConstants.SERIALIZATION_LIB,storageHandler.getSerDeClass().getName()); + TableDesc tableDesc = new TableDesc(storageHandler.getInputFormatClass(), IgnoreKeyTextOutputFormat.class,props); if (tableDesc.getJobProperties() == null) tableDesc.setJobProperties(new HashMap());