Repository: sqoop Updated Branches: refs/heads/sqoop2 c812ec586 -> bbb9aff55
SQOOP-2397: Sqoop2: Propagate CSVWriter in Kite connector to execution engine (Richard 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/bbb9aff5 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/bbb9aff5 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/bbb9aff5 Branch: refs/heads/sqoop2 Commit: bbb9aff55d40b2e6e8c06d1908451cb1cbeeb0f1 Parents: c812ec5 Author: Jarek Jarcec Cecho <[email protected]> Authored: Wed Jul 8 16:37:11 2015 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Wed Jul 8 16:37:11 2015 -0700 ---------------------------------------------------------------------- .../java/org/apache/sqoop/connector/kite/KiteFromInitializer.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/bbb9aff5/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteFromInitializer.java ---------------------------------------------------------------------- diff --git a/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteFromInitializer.java b/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteFromInitializer.java index ed79314..28c5bac 100644 --- a/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteFromInitializer.java +++ b/connector/connector-kite/src/main/java/org/apache/sqoop/connector/kite/KiteFromInitializer.java @@ -67,6 +67,7 @@ public class KiteFromInitializer extends Initializer<LinkConfiguration, jars.add(ClassUtils.jarForClass("parquet.org.codehaus.jackson.type.TypeReference")); jars.add(ClassUtils.jarForClass("parquet.bytes.CapacityByteArrayOutputStream")); jars.add(ClassUtils.jarForClass("parquet.encoding.Generator")); + jars.add(ClassUtils.jarForClass("au.com.bytecode.opencsv.CSVWriter")); if (fromJobConfig.fromJobConfig.uri.startsWith("dataset:hive")) { // @TODO(Abe): Remove a deps that aren't used? jars.add(ClassUtils.jarForClass("org.apache.hadoop.hive.conf.HiveConf"));
