Repository: sqoop Updated Branches: refs/heads/trunk 79b717269 -> 314dfa043
SQOOP-1520: The table is null when using import into hive as parquet file and query option (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/314dfa04 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/314dfa04 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/314dfa04 Branch: refs/heads/trunk Commit: 314dfa0433b36bef25ed81c6a9b7526101c00110 Parents: 79b7172 Author: Jarek Jarcec Cecho <[email protected]> Authored: Wed Sep 17 09:44:27 2014 +0200 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Wed Sep 17 09:44:27 2014 +0200 ---------------------------------------------------------------------- src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/314dfa04/src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java b/src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java index 938948f..71abeeb 100644 --- a/src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java +++ b/src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java @@ -104,7 +104,7 @@ public class DataDrivenImportJob extends ImportJobBase { Schema schema = generateAvroSchema(tableName); String uri; if (options.doHiveImport()) { - uri = "dataset:hive?dataset=" + options.getTableName(); + uri = "dataset:hive?dataset=" + options.getHiveTableName(); } else { FileSystem fs = FileSystem.get(conf); uri = "dataset:" + fs.makeQualified(getContext().getDestination());
