change

src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBSubscribe.java

@@ -14,12 +14,11 @@
  *****************************************************************************/
 package com.taosdata.jdbc;
 
-import javax.management.OperationsException;
 import java.sql.SQLException;
 
 public class TSDBSubscribe {
-    private TSDBJNIConnector connecter = null;
-    private long id = 0;
+    private final TSDBJNIConnector connecter;
+    private final long id;
 
     TSDBSubscribe(TSDBJNIConnector connecter, long id) throws SQLException {
         if (null != connecter) {

src/connector/jdbc/src/test/java/com/taosdata/jdbc/ResultSetTest.java

@@ -13,7 +13,6 @@ import java.util.HashMap;
 import java.util.Properties;
 
 import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
 
 public class ResultSetTest {
     static Connection connection;

src/connector/jdbc/src/test/java/com/taosdata/jdbc/SubscribeTest.java

@@ -48,7 +48,6 @@ public class SubscribeTest {
     @Test
     public void subscribe() {
         try {
-
             String rawSql = "select * from " + dbName + "." + tName + ";";
             System.out.println(rawSql);
             TSDBSubscribe subscribe = ((TSDBConnection) connection).subscribe(topic, rawSql, false);
@@ -67,10 +66,10 @@ public class SubscribeTest {
                 if (a >= 2) {
                     break;
                 }
-//                resSet.close();
+                resSet.close();
             }
 
-            subscribe.close(true);
+            subscribe.close(false);
         } catch (Exception e) {
             e.printStackTrace();
         }