sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From va...@apache.org
Subject sqoop git commit: SQOOP-3082: Sqoop import fails after TCP connection reset if split by datetime column
Date Fri, 18 May 2018 09:33:40 GMT
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 <vasas@apache.org>
Authored: Fri May 18 11:32:35 2018 +0200
Committer: Szabolcs Vasas <vasas@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(),


Mime
View raw message