From ad7d046ef1d68b46aacdf6e124056f5901e95e5c Mon Sep 17 00:00:00 2001 From: Szabolcs Vasas Date: Fri, 18 May 2018 11:32:35 +0200 Subject: [PATCH] SQOOP-3082: Sqoop import fails after TCP connection reset if split by datetime column (Sergey Svynarchuk via Szabolcs Vasas) --- .../org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java b/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java index 2c8a9fd2..c879c709 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 @@ protected String getSelectQuery() { 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(),