You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/09/23 01:13:09 UTC
[iotdb] branch master updated: terminate workerMonitorExecutor (#7404)
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 f99850c542 terminate workerMonitorExecutor (#7404)
f99850c542 is described below
commit f99850c542ff12749de25841aa0ac5f17f5ff5d2
Author: Itami Sho <42...@users.noreply.github.com>
AuthorDate: Fri Sep 23 09:13:03 2022 +0800
terminate workerMonitorExecutor (#7404)
---
.../java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
index 67980f6404..da84be1cd9 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
@@ -858,6 +858,7 @@ public class ProcedureExecutor<Env> {
public void join() {
timeoutExecutor.awaitTermination();
+ workerMonitorExecutor.awaitTermination();
for (WorkerThread workerThread : workerThreads) {
workerThread.awaitTermination();
}