[incubator-iotdb] 01/01: shutdown uncessary threadpool

[qi...@apache.org]

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 <64...@qq.com>
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();
     }
   }