commit d8c4b3ccdd06c5e300e4552b962e97c714651797
author Venkat Ranganathan <venkat@hortonworks.com> Thu Feb 23 08:06:16 2017 -0800
committer Venkat Ranganathan <venkat@hortonworks.com> Thu Feb 23 08:06:16 2017 -0800
tree 5a13bd242921d7c6d1dbf06e0ac6eb27b1d7b913
parent 24d08185c502e416265f1fa78300347ad02a4e1f

SQOOP-3138: Netezza Direct Import does not support --columns options
   (Suraj Nayak  via Venkat Ranganathan)

src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java

diff --git a/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java b/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java
index 2efea53..0b4b134 100644
--- a/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java
+++ b/src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java
@@ -80,7 +80,7 @@
     int errorThreshold = conf.getInt(
       DirectNetezzaManager.NETEZZA_ERROR_THRESHOLD_OPT, 1);
     String logDir = conf.get(DirectNetezzaManager.NETEZZA_LOG_DIR_OPT);
-    String[] cols = dbc.getOutputFieldNames();
+    String[] cols = dbc.getInputFieldNames();
     String inputConds = dbc.getInputConditions();
     StringBuilder sqlStmt = new StringBuilder(2048);
 
@@ -125,7 +125,7 @@
       sqlStmt.append('*');
     } else {
       sqlStmt.append(cols[0]).append(' ');
-      for (int i = 0; i < cols.length; ++i) {
+      for (int i = 1; i < cols.length; ++i) {
         sqlStmt.append(',').append(cols[i]);
       }
     }