[iotdb] branch client_manager_add_close updated: fix unstopped members

[jiangtian]

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

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


The following commit(s) were added to refs/heads/client_manager_add_close by 
this push:
     new df88404  fix unstopped members
df88404 is described below

commit df884042ae924f253e228489c59641abd6b34314
Author: jt <jt2594...@163.com>
AuthorDate: Wed Jan 5 16:12:25 2022 +0800

    fix unstopped members
---
 .../java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java   | 1 +
 .../apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java  | 1 +
 .../cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java      | 1 +
 .../iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java      | 1 +
 4 files changed, 4 insertions(+)

diff --git 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java
 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java
index e1bea55..bb609bb 100644
--- 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java
+++ 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/DatasourceInfoTest.java
@@ -89,6 +89,7 @@ public class DatasourceInfoTest {
 
   @After
   public void tearDown() {
+    metaGroupMember.stop();
     ClusterIoTDB.getInstance().setClientManager(clientManager);
   }
 
diff --git 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
index 8ba4021..37b42d7 100644
--- 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
+++ 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
@@ -142,6 +142,7 @@ public class RemoteSimpleSeriesReaderTest {
 
   @After
   public void tearDown() {
+    metaGroupMember.stop();
     
ClusterDescriptor.getInstance().getConfig().setUseAsyncServer(prevUseAsyncServer);
   }
 
diff --git 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
index 4ee0965..5b05f83 100644
--- 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
+++ 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
@@ -94,6 +94,7 @@ public class AssignPathManagedMergeReaderTest {
 
   @After
   public void tearDown() {
+    metaGroupMember.stop();
     
ClusterDescriptor.getInstance().getConfig().setUseAsyncServer(prevUseAsyncServer);
   }
 
diff --git 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
index 9797c7c..dff7e3c 100644
--- 
a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
+++ 
b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
@@ -110,6 +110,7 @@ public class RemoteMultSeriesReaderTest {
 
   @After
   public void tearDown() {
+    metaGroupMember.stop();
     
ClusterDescriptor.getInstance().getConfig().setUseAsyncServer(prevUseAsyncServer);
   }