You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by va...@apache.org on 2018/05/18 09:33:40 UTC
sqoop git commit: SQOOP-3082: Sqoop import fails after TCP connection
reset if split by datetime column
Repository: sqoop
Updated Branches:
refs/heads/trunk 6c0b32012 -> ad7d046ef
SQOOP-3082: Sqoop import fails after TCP connection reset if split by datetime column
(Sergey Svynarchuk via Szabolcs Vasas)
Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/ad7d046e
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/ad7d046e
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/ad7d046e
Branch: refs/heads/trunk
Commit: ad7d046ef1d68b46aacdf6e124056f5901e95e5c
Parents: 6c0b320
Author: Szabolcs Vasas <va...@apache.org>
Authored: Fri May 18 11:32:35 2018 +0200
Committer: Szabolcs Vasas <va...@apache.org>
Committed: Fri May 18 11:32:35 2018 +0200
----------------------------------------------------------------------
.../org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/sqoop/blob/ad7d046e/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java b/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java
index 2c8a9fd..c879c70 100644
--- a/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java
+++ b/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java
@@ -242,7 +242,7 @@ public class SQLServerDBRecordReader<T extends SqoopRecord> extends
StringBuilder lowerClause = new StringBuilder();
lowerClause.append(getDBConf().getInputOrderBy());
lowerClause.append(" > ");
- lowerClause.append(lastRecordValue.toString());
+ lowerClause.append("'" + lastRecordValue.toString() + "'");
// Get the select query with the lowerClause, and split upper clause
selectQuery = getSelectQuery(lowerClause.toString(),