Updated Branches: refs/heads/sqoop2 74ebecb7c -> a3abffcd5
SQOOP-1130: Sqoop2: Sqoop MapReduce Job Failed when max and min boundary are both null (Mengwei Ding via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/a3abffcd Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/a3abffcd Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/a3abffcd Branch: refs/heads/sqoop2 Commit: a3abffcd591f16a5f4f47fa43eeef7dcdec68cf7 Parents: 74ebecb Author: Jarek Jarcec Cecho <[email protected]> Authored: Thu Jul 11 15:29:04 2013 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Thu Jul 11 15:29:04 2013 -0700 ---------------------------------------------------------------------- .../apache/sqoop/connector/jdbc/GenericJdbcImportPartitioner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/a3abffcd/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportPartitioner.java ---------------------------------------------------------------------- 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 4401800..7792c57 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 class GenericJdbcImportPartitioner extends Partitioner<ConnectionConfigur if (partitionMinValue == null && partitionMaxValue == null) { List<Partition> partitions = new LinkedList<Partition>(); GenericJdbcImportPartition partition = new GenericJdbcImportPartition(); - partition.setConditions(partitionColumnName + "IS NULL"); + partition.setConditions(partitionColumnName + " IS NULL"); partitions.add(partition); return partitions; }
