[iotdb] 01/01: make snapshot taking in shutdown hook parallel

[ma...@apache.org]

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

marklau99 pushed a commit to branch IOTDB-5031
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit f848547974738812ee5beb823eba267f15e41709
Author: Liu Xuxin <li...@outlook.com>
AuthorDate: Thu Nov 24 17:27:17 2022 +0800

    make snapshot taking in shutdown hook parallel
---
 .../src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java b/server/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java
index e5ac9e69d8..ade8f9a7f0 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java
@@ -56,8 +56,7 @@ public class IoTDBShutdownHook extends Thread {
     if (IoTDBDescriptor.getInstance().getConfig().isClusterMode()) {
       // This setting ensures that compaction work is not discarded
       // even if there are frequent restarts
-      DataRegionConsensusImpl.getInstance()
-          .getAllConsensusGroupIds()
+      DataRegionConsensusImpl.getInstance().getAllConsensusGroupIds().parallelStream()
           .forEach(id -> DataRegionConsensusImpl.getInstance().triggerSnapshot(id));
     }