Removed cleaning of unclosed result set

alex268 · Sep 30, 2024 · 96ccf40 · 96ccf40
1 parent f7435de
commit 96ccf40
Showing 1 changed file with 3 additions and 8 deletions.
diff --git a/jdbc/src/main/java/tech/ydb/jdbc/context/StreamQueryResult.java b/jdbc/src/main/java/tech/ydb/jdbc/context/StreamQueryResult.java
@@ -148,17 +148,15 @@ private void closeResultSet(int index) throws SQLException {
  }
  }
 
- private boolean isStreamStopped() {
+ private void checkStream() {
  if (!resultClosed) {
- return false;
+ return;
  }
 
  if (!streamFuture.isDone() && streamCancelled.compareAndSet(false, true)) {
  LOGGER.log(Level.FINE, "Stream cancel");
  stopRunnable.run();
  }
-
- return true;
  }
 
  @Override
@@ -311,10 +309,7 @@ public void cleanQueue() {
  public void addResultSet(ResultSetReader rsr) {
  try {
  do {
- if (isStreamStopped()) {
- close();
- return;
- }
+ checkStream();
  } while (!readers.offer(rsr, 100, TimeUnit.MILLISECONDS));
  } catch (InterruptedException ex) {
  if (streamFuture.completeExceptionally(ex)) {