This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch take_snapshot_enhancement in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ff3da73b10e88bc618302ef78dd23b1b562ecae7 Author: YongzaoDan <[email protected]> AuthorDate: Tue Jun 27 21:24:05 2023 +0800 [To rel/1.2][IOTDB-6030] Improve efficiency of ConfigNode PartitionInfo takeSnapshot (#10336) * Finish * unparallel take snapshot --- .../iotdb/confignode/persistence/partition/PartitionInfo.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java index 468d50b0070..641d21b4f87 100644 --- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java +++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java @@ -69,9 +69,8 @@ import org.apache.thrift.transport.TIOStreamTransport; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.io.BufferedOutputStream; import java.io.File; -import java.io.FileInputStream; -import java.io.FileOutputStream; import java.io.IOException; import java.util.ArrayList; import java.util.Collections; @@ -728,7 +727,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);
