diff --git src/java/org/apache/hcatalog/pig/HCatLoader.java src/java/org/apache/hcatalog/pig/HCatLoader.java index b5754b9..826174f 100644 --- src/java/org/apache/hcatalog/pig/HCatLoader.java +++ src/java/org/apache/hcatalog/pig/HCatLoader.java @@ -119,7 +119,7 @@ public class HCatLoader extends HCatBaseLoader { // udf context, so the the HCatInputFormat.setInput method need not //be called many times. for (Entry keyValue : job.getConfiguration()) { - String oldValue = clone.getConfiguration().get(keyValue.getKey()); + String oldValue = clone.getConfiguration().getRaw(keyValue.getKey()); if ((oldValue == null) || (keyValue.getValue().equals(oldValue) == false)) { udfProps.put(keyValue.getKey(), keyValue.getValue()); } diff --git src/java/org/apache/hcatalog/pig/HCatStorer.java src/java/org/apache/hcatalog/pig/HCatStorer.java index e92659b..b894bd4 100644 --- src/java/org/apache/hcatalog/pig/HCatStorer.java +++ src/java/org/apache/hcatalog/pig/HCatStorer.java @@ -136,7 +136,7 @@ public class HCatStorer extends HCatBaseStorer { // udf context, so the the HCatOutputFormat.setOutput and setSchema // methods need not be called many times. for ( Entry keyValue : job.getConfiguration()) { - String oldValue = clone.getConfiguration().get(keyValue.getKey()); + String oldValue = clone.getConfiguration().getRaw(keyValue.getKey()); if ((oldValue == null) || (keyValue.getValue().equals(oldValue) == false)) { udfProps.put(keyValue.getKey(), keyValue.getValue()); }