This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch shutdown_recover_thread_pool in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 2ef7aaa4cd6dcb615904936a8bf23def685401cb Author: qiaojialin <[email protected]> AuthorDate: Mon Jun 1 15:28:28 2020 +0800 shutdown uncessary threadpool --- server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java | 1 + .../org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 2 ++ 2 files changed, 3 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java index ca6fc86..65f99d4 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java @@ -181,6 +181,7 @@ public class StorageEngine implements IService { throw new StorageEngineFailureException("StorageEngine failed to recover.", e); } } + recoveryThreadPool.shutdown(); } @Override diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java index 80a915a..6f85824 100755 --- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java @@ -80,6 +80,7 @@ import org.apache.iotdb.db.qp.physical.crud.InsertPlan; import org.apache.iotdb.db.qp.physical.crud.InsertTabletPlan; import org.apache.iotdb.db.query.context.QueryContext; import org.apache.iotdb.db.query.control.QueryFileManager; +import org.apache.iotdb.db.service.UpgradeSevice; import org.apache.iotdb.db.utils.CopyOnReadLinkedList; import org.apache.iotdb.db.writelog.recover.TsFileRecoverPerformer; import org.apache.iotdb.rpc.RpcUtils; @@ -1537,6 +1538,7 @@ public class StorageGroupProcessor { } } } + UpgradeSevice.getINSTANCE().stop(); } }
