FlinkResultSet#close will do nothing if all results are fetched from …

…a job
hameizi · Apr 8, 2020 · a24cc26 · a24cc26
1 parent da1ed7f
commit a24cc26
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/main/java/com/ververica/flink/table/jdbc/FlinkResultSet.java b/src/main/java/com/ververica/flink/table/jdbc/FlinkResultSet.java
@@ -114,7 +114,7 @@ public synchronized void close() throws SQLException {
 			return;
 		}
 
-		if (jobIdOrResultSet.isLeft()) {
+		if (jobIdOrResultSet.isLeft() && rowData.hasMoreResponse()) {
 			// no need to lock, closing while fetching new results should throw exception
 			session.cancelJob(jobIdOrResultSet.left());
 		}
@@ -1395,6 +1395,10 @@ boolean isAfterLast() {
 			return ret;
 		}
 
+		boolean hasMoreResponse() {
+			return hasMoreResponse;
+		}
+
 		Row getCurrentRow() {
 			lock.readLock().lock();
 			Row ret = currentRow;