From a3abffcd591f16a5f4f47fa43eeef7dcdec68cf7 Mon Sep 17 00:00:00 2001 From: Jarek Jarcec Cecho Date: Thu, 11 Jul 2013 15:29:04 -0700 Subject: [PATCH] SQOOP-1130: Sqoop2: Sqoop MapReduce Job Failed when max and min boundary are both null (Mengwei Ding via Jarek Jarcec Cecho) --- .../sqoop/connector/jdbc/GenericJdbcImportPartitioner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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; }