You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ab...@apache.org on 2014/10/19 18:41:07 UTC
git commit: SQOOP-1581: Sqoop2: LoaderContext has the wrong Schema
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 <ab...@elmahrek.com>
Authored: Sun Oct 19 12:01:17 2014 -0400
Committer: Abraham Elmahrek <ab...@elmahrek.com>
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);