Repository: sqoop Updated Branches: refs/heads/trunk c859a5a15 -> e247f76bf
SQOOP-1423: hcatalog export with --map-column-java fails (Muhammad Ehsan ul Haque via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/e247f76b Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/e247f76b Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/e247f76b Branch: refs/heads/trunk Commit: e247f76bfa1a58e5b39dda686c43e884a49bfadc Parents: c859a5a Author: Jarek Jarcec Cecho <[email protected]> Authored: Sat Aug 9 10:41:04 2014 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Sat Aug 9 10:41:04 2014 -0700 ---------------------------------------------------------------------- .../apache/sqoop/mapreduce/hcat/SqoopHCatUtilities.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/e247f76b/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatUtilities.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatUtilities.java b/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatUtilities.java index 05b454d..b69b83e 100644 --- a/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatUtilities.java +++ b/src/java/org/apache/sqoop/mapreduce/hcat/SqoopHCatUtilities.java @@ -798,10 +798,16 @@ public final class SqoopHCatUtilities { job.setInputFormatClass(getInputFormatClass()); Map<String, List<Integer>> dbColInfo = hCatUtils.getDbColumnInfo(); MapWritable columnTypesJava = new MapWritable(); + Properties mapColumnJava = opts.getMapColumnJava(); for (Map.Entry<String, List<Integer>> e : dbColInfo.entrySet()) { Text columnName = new Text(e.getKey()); - Text columnText = new Text(connMgr.toJavaType(dbTable, e.getKey(), - e.getValue().get(0))); + Text columnText = null; + if (mapColumnJava.containsKey(e.getKey())) { + columnText = new Text(mapColumnJava.getProperty(e.getKey())); + } else { + columnText = new Text(connMgr.toJavaType(dbTable, e.getKey(), + e.getValue().get(0))); + } columnTypesJava.put(columnName, columnText); } MapWritable columnTypesSql = new MapWritable();
