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 eb46eb84d5d Revert "[IOTDB-6030] Improve efficiency of ConfigNode PartitionInfo takeSnapshot (#10335)" (#10344) eb46eb84d5d is described below commit eb46eb84d5d99d23bf796a7d2a1ba522980e3901 Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn> AuthorDate: Tue Jun 27 19:51:50 2023 +0800 Revert "[IOTDB-6030] Improve efficiency of ConfigNode PartitionInfo takeSnapshot (#10335)" (#10344) This reverts commit 25edadc08353c36afe022ea15da76e2f39229b4d. --- .../iotdb/confignode/persistence/partition/PartitionInfo.java | 6 ++---- 1 file changed, 2 insertions(+), 4 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 7b3c6629931..c6a74c1313e 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 @@ -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,9 +780,7 @@ public class PartitionInfo implements SnapshotProcessor { // snapshot operation. File tmpFile = new File(snapshotFile.getAbsolutePath() + "-" + UUID.randomUUID()); - try (BufferedOutputStream fileOutputStream = - new BufferedOutputStream( - Files.newOutputStream(tmpFile.toPath()), PARTITION_TABLE_BUFFER_SIZE); + try (FileOutputStream fileOutputStream = new FileOutputStream(tmpFile); TIOStreamTransport tioStreamTransport = new TIOStreamTransport(fileOutputStream)) { TProtocol protocol = new TBinaryProtocol(tioStreamTransport);