diff --git a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportPartitioner.java b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportPartitioner.java index 44018008..7792c574 100644 --- a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportPartitioner.java +++ b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportPartitioner.java @@ -57,7 +57,7 @@ public List getPartitions(PartitionerContext context,ConnectionConfig if (partitionMinValue == null && partitionMaxValue == null) { List partitions = new LinkedList(); GenericJdbcImportPartition partition = new GenericJdbcImportPartition(); - partition.setConditions(partitionColumnName + "IS NULL"); + partition.setConditions(partitionColumnName + " IS NULL"); partitions.add(partition); return partitions; }