github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-03 05:50:31 +08:00
Code Issues Projects Releases Wiki Activity

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

Browse Source 
(Sergey Svynarchuk via Szabolcs Vasas)
This commit is contained in:
Szabolcs Vasas 2018-05-18 11:32:35 +02:00
parent 6c0b320128
commit ad7d046ef1
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java
View File

@ -242,7 +242,7 @@ protected String getSelectQuery() {
StringBuilder lowerClause = new StringBuilder(); StringBuilder lowerClause = new StringBuilder();
lowerClause.append(getDBConf().getInputOrderBy()); lowerClause.append(getDBConf().getInputOrderBy());
lowerClause.append(" > "); lowerClause.append(" > ");
lowerClause.append(lastRecordValue.toString()); lowerClause.append("'" + lastRecordValue.toString() + "'");
// Get the select query with the lowerClause, and split upper clause // Get the select query with the lowerClause, and split upper clause
selectQuery = getSelectQuery(lowerClause.toString(), selectQuery = getSelectQuery(lowerClause.toString(),