You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/01/05 08:13:03 UTC
[iotdb] branch client_manager_add_close updated: fix unstopped members
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 <jt...@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);
}