[iotdb] branch master updated: fix: Fix `SessionDataSet` not close automatically (#6134)

[qiaojialin]

This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 964f3218b5 fix: Fix `SessionDataSet` not close automatically (#6134)
964f3218b5 is described below

commit 964f3218b52644d1ba207244c66109ec16266787
Author: wallezhang <doraemon...@gmail.com>
AuthorDate: Wed Jun 1 23:11:17 2022 +0800

    fix: Fix `SessionDataSet` not close automatically (#6134)
---
 .../src/main/java/org/apache/iotdb/cluster/ClientMain.java   | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/ClientMain.java 
b/cluster/src/main/java/org/apache/iotdb/cluster/ClientMain.java
index a8003e2a4c..30b0a3bf93 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/ClientMain.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/ClientMain.java
@@ -327,7 +327,7 @@ public class ClientMain {
       logger.info(resp.columns.toString());
     }
 
-    SessionDataSet dataSet =
+    try (SessionDataSet dataSet =
         new SessionDataSet(
             query,
             resp.getColumns(),
@@ -338,11 +338,11 @@ public class ClientMain {
             client,
             sessionId,
             resp.queryDataSet,
-            false);
-
-    while (dataSet.hasNext()) {
-      if (logger.isInfoEnabled()) {
-        logger.info(dataSet.next().toString());
+            false)) {
+      while (dataSet.hasNext()) {
+        if (logger.isInfoEnabled()) {
+          logger.info(dataSet.next().toString());
+        }
       }
     }
     System.out.println();