[iotdb] branch master updated: [IOTDB-6030] Improve efficiency of ConfigNode PartitionInfo takeSnapshot (#10348)

[qiaojialin]

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 e35e1f3e9b6 [IOTDB-6030] Improve efficiency of ConfigNode 
PartitionInfo takeSnapshot (#10348)
e35e1f3e9b6 is described below

commit e35e1f3e9b6f01f7c0febb8c20ba6555bed5ec27
Author: YongzaoDan <33111881+crzbulab...@users.noreply.github.com>
AuthorDate: Wed Jun 28 10:19:45 2023 +0800

    [IOTDB-6030] Improve efficiency of ConfigNode PartitionInfo takeSnapshot 
(#10348)
---
 .../iotdb/confignode/persistence/partition/PartitionInfo.java       | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
index 10f73d0c95b..6267f56e6b6 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
@@ -72,8 +72,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
 import java.io.File;
-import java.io.FileOutputStream;
 import java.io.IOException;
 import java.nio.file.Files;
 import java.util.ArrayList;
@@ -780,7 +780,9 @@ public class PartitionInfo implements SnapshotProcessor {
     // snapshot operation.
     File tmpFile = new File(snapshotFile.getAbsolutePath() + "-" + 
UUID.randomUUID());
 
-    try (FileOutputStream fileOutputStream = new FileOutputStream(tmpFile);
+    try (BufferedOutputStream fileOutputStream =
+            new BufferedOutputStream(
+                Files.newOutputStream(tmpFile.toPath()), 
PARTITION_TABLE_BUFFER_SIZE);
         TIOStreamTransport tioStreamTransport = new 
TIOStreamTransport(fileOutputStream)) {
       TProtocol protocol = new TBinaryProtocol(tioStreamTransport);