diff --git a/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java b/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java index 2472a884..4c03c0d7 100644 --- a/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java +++ b/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java @@ -272,8 +272,7 @@ public boolean nextKeyValue() throws IOException { */ protected boolean isDone() { try { - return this.results != null - && (results.isLast() || results.isAfterLast()); + return this.results != null && results.isAfterLast(); } catch (SQLException sqlE) { return true; }