Repository: sqoop Updated Branches: refs/heads/sqoop2 cb8214806 -> 3257b3855
SQOOP-1581: Sqoop2: LoaderContext has the wrong Schema (Qian Xu via Abraham Elmahrek) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/3257b385 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/3257b385 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/3257b385 Branch: refs/heads/sqoop2 Commit: 3257b385555f412b962195a8fb0e1d522d9fa661 Parents: cb82148 Author: Abraham Elmahrek <[email protected]> Authored: Sun Oct 19 12:01:17 2014 -0400 Committer: Abraham Elmahrek <[email protected]> Committed: Sun Oct 19 12:01:17 2014 -0400 ---------------------------------------------------------------------- .../org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/3257b385/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java ---------------------------------------------------------------------- diff --git a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java index 9108981..8aad936 100644 --- a/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java +++ b/execution/mapreduce/src/main/java/org/apache/sqoop/job/mr/SqoopOutputFormatLoadExecutor.java @@ -233,7 +233,7 @@ public class SqoopOutputFormatLoadExecutor { if (!isTest) { // Using the TO schema since the IDF returns data in TO schema - schema = MRConfigurationUtils.getConnectorSchema(Direction.TO, conf); + schema = matcher.getToSchema(); subContext = new PrefixContext(conf, MRJobConstants.PREFIX_CONNECTOR_TO_CONTEXT); configConnection = MRConfigurationUtils.getConnectorConnectionConfig(Direction.TO, conf);
