You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2013/07/12 00:29:55 UTC

git commit: SQOOP-1130: Sqoop2: Sqoop MapReduce Job Failed when max and min boundary are both null

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 <ja...@apache.org>
Authored: Thu Jul 11 15:29:04 2013 -0700
Committer: Jarek Jarcec Cecho <ja...@apache.org>
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;
     }