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;
}