commit ad7d046ef1d68b46aacdf6e124056f5901e95e5c
author Szabolcs Vasas <vasas@apache.org> Fri May 18 11:32:35 2018 +0200
committer Szabolcs Vasas <vasas@apache.org> Fri May 18 11:32:35 2018 +0200
tree 132e34f9afcfbb994eb30dc1fd40799a7dbb4e4f
parent 6c0b3201280f3c7c4c56530909fbb2977e58542e

SQOOP-3082: Sqoop import fails after TCP connection reset if split by datetime column

(Sergey Svynarchuk via Szabolcs Vasas)

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 @@
       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(),