diff --git a/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableExportJob.java b/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableExportJob.java index 117cc3f0..e0da07c5 100644 --- a/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableExportJob.java +++ b/src/java/org/apache/sqoop/mapreduce/netezza/NetezzaExternalTableExportJob.java @@ -125,7 +125,7 @@ protected void configureOutputFormat(Job job, String tableName, String [] colNames = options.getColumns(); if (null == colNames) { - colNames = mgr.getColumnNames(tableName); + colNames = mgr.getColumnNames(tableName.substring(tableName.lastIndexOf('.')+1)); } if (mgr.escapeTableNameOnExport()) {