From 13240d10024fd961b3b6a3698e4a3d64a2d83bb0 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 9 Apr 2026 11:22:59 +0800 Subject: [PATCH 1/8] fix --- .../resource/memory/PipeMemoryWeightUtil.java | 33 ++++++++++++------- .../iotdb/commons/conf/CommonConfig.java | 4 ++- 2 files changed, 24 insertions(+), 13 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java index 458434d84942b..79d49440d67a0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java @@ -118,7 +118,10 @@ public static Pair calculateTabletRowCountAndMemory(RowRecord } } - return calculateTabletRowCountAndMemoryBySize(totalSizeInBytes, schemaCount); + return calculateTabletRowCountAndMemoryBySize( + totalSizeInBytes, + schemaCount, + PipeConfig.getInstance().getPipeDataStructureTabletRowSize()); } /** @@ -163,7 +166,8 @@ public static Pair calculateTabletRowCountAndMemory(BatchData } } - return calculateTabletRowCountAndMemoryBySize(totalSizeInBytes, schemaCount); + return calculateTabletRowCountAndMemoryBySize( + totalSizeInBytes, schemaCount, batchData.length()); } /** @@ -173,22 +177,28 @@ public static Pair calculateTabletRowCountAndMemory(BatchData * @return left is the row count of tablet, right is the memory cost of tablet in bytes */ public static Pair calculateTabletRowCountAndMemory(PipeRow row) { - return calculateTabletRowCountAndMemoryBySize(row.getCurrentRowSize(), row.size()); + return calculateTabletRowCountAndMemoryBySize( + row.getCurrentRowSize(), + row.size(), + PipeConfig.getInstance().getPipeDataStructureTabletRowSize()); } private static Pair calculateTabletRowCountAndMemoryBySize( - int rowSize, int schemaCount) { - if (rowSize <= 0) { + int rowBytesUsed, int schemaCount, int inputNum) { + if (rowBytesUsed <= 0) { return new Pair<>(1, 0); } // Calculate row number according to the max size of a pipe tablet. // "-100" is the estimated size of other data structures in a pipe tablet. // "*8" converts bytes to bits, because the bitmap size is 1 bit per schema. - int rowNumber = - 8 - * (PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes() - 100) - / (8 * rowSize + schemaCount); + // Here we estimate the max use of + int sizeLimit = + Math.min( + PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes(), + (int) (inputNum * rowBytesUsed * 1.2)); + + int rowNumber = 8 * (sizeLimit - 100) / (8 * rowBytesUsed + schemaCount); rowNumber = Math.max(1, rowNumber); if ( // This means the row number is larger than the max row count of a pipe tablet @@ -196,10 +206,9 @@ private static Pair calculateTabletRowCountAndMemoryBySize( // Bound the row number, the memory cost is rowSize * rowNumber return new Pair<>( PipeConfig.getInstance().getPipeDataStructureTabletRowSize(), - rowSize * PipeConfig.getInstance().getPipeDataStructureTabletRowSize()); + rowBytesUsed * PipeConfig.getInstance().getPipeDataStructureTabletRowSize()); } else { - return new Pair<>( - rowNumber, PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes()); + return new Pair<>(rowNumber, sizeLimit); } } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java index ff4a47b6f84ab..8550801af1ced 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java @@ -218,7 +218,9 @@ public class CommonConfig { private boolean pipeRetryLocallyForParallelOrUserConflict = true; private int pipeDataStructureTabletRowSize = 2048; - private int pipeDataStructureTabletSizeInBytes = 2097152; + + // 128MB + private int pipeDataStructureTabletSizeInBytes = 128 * 1024 * 1024; private double pipeDataStructureTabletMemoryBlockAllocationRejectThreshold = 0.3; private double pipeDataStructureTsFileMemoryBlockAllocationRejectThreshold = 0.3; private volatile double pipeTotalFloatingMemoryProportion = 0.5; From 368971ad74ad098b26b4ae4fe548c4f522404cc1 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 9 Apr 2026 14:07:46 +0800 Subject: [PATCH 2/8] push --- .../pipe/event/TsFileInsertionEventParserTest.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java index 8814190755e27..a2e7c558ea0b5 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java @@ -19,7 +19,9 @@ package org.apache.iotdb.db.pipe.event; +import org.apache.iotdb.commons.conf.CommonDescriptor; import org.apache.iotdb.commons.path.PartialPath; +import org.apache.iotdb.commons.pipe.config.PipeConfig; import org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBTreePattern; import org.apache.iotdb.commons.pipe.datastructure.pattern.PrefixTreePattern; import org.apache.iotdb.commons.pipe.datastructure.pattern.TreePattern; @@ -48,6 +50,7 @@ import org.apache.tsfile.write.schema.MeasurementSchema; import org.junit.After; import org.junit.Assert; +import org.junit.Before; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -79,9 +82,19 @@ public class TsFileInsertionEventParserTest { private File alignedTsFile; private File nonalignedTsFile; private TsFileResource resource; + private boolean isPipeMemoryManagementEnabled; + + @Before + public void setUp() throws Exception { + isPipeMemoryManagementEnabled = PipeConfig.getInstance().getPipeMemoryManagementEnabled(); + CommonDescriptor.getInstance().getConfig().setPipeMemoryManagementEnabled(false); + } @After public void tearDown() throws Exception { + CommonDescriptor.getInstance() + .getConfig() + .setPipeMemoryManagementEnabled(isPipeMemoryManagementEnabled); if (alignedTsFile != null) { alignedTsFile.delete(); } From 1ea87337157ec0f239a47a5354eecdd0aec6497d Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 9 Apr 2026 14:12:43 +0800 Subject: [PATCH 3/8] ger-limit --- .../main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java index 8550801af1ced..0f6dbe989e1f9 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java @@ -220,7 +220,7 @@ public class CommonConfig { private int pipeDataStructureTabletRowSize = 2048; // 128MB - private int pipeDataStructureTabletSizeInBytes = 128 * 1024 * 1024; + private int pipeDataStructureTabletSizeInBytes = 60 * 1024 * 1024; private double pipeDataStructureTabletMemoryBlockAllocationRejectThreshold = 0.3; private double pipeDataStructureTsFileMemoryBlockAllocationRejectThreshold = 0.3; private volatile double pipeTotalFloatingMemoryProportion = 0.5; From 5cdfe87eab9915ab36ddabbcd4972a54dc6ad96d Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 9 Apr 2026 15:23:11 +0800 Subject: [PATCH 4/8] fix --- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 ++++++++++ .../tsfile/parser/TsFileInsertionEventParser.java | 4 ++-- .../parser/scan/TsFileInsertionEventScanParser.java | 3 ++- .../parser/table/TsFileInsertionEventTableParser.java | 6 ++++-- .../db/pipe/resource/memory/PipeMemoryWeightUtil.java | 3 ++- 5 files changed, 20 insertions(+), 6 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java index 69eab2d79cf28..31f446df27031 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java @@ -25,6 +25,7 @@ import org.apache.iotdb.commons.conf.CommonDescriptor; import org.apache.iotdb.commons.conf.IoTDBConstant; import org.apache.iotdb.commons.enums.ReadConsistencyLevel; +import org.apache.iotdb.commons.pipe.config.PipeConfig; import org.apache.iotdb.commons.utils.FileUtils; import org.apache.iotdb.consensus.ConsensusFactory; import org.apache.iotdb.db.exception.LoadConfigurationException; @@ -3287,6 +3288,15 @@ public void setPartitionCacheSize(int partitionCacheSize) { this.partitionCacheSize = partitionCacheSize; } + public int getPipeDataStructureTabletSizeInBytes() { + int size = PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes(); + if (size > thriftMaxFrameSize) { + size = (int) (thriftMaxFrameSize * 0.8); + CommonDescriptor.getInstance().getConfig().setPipeDataStructureTabletSizeInBytes(size); + } + return size; + } + public int getAuthorCacheSize() { return authorCacheSize; } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/TsFileInsertionEventParser.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/TsFileInsertionEventParser.java index 82f3e0ea2b841..678e7a4a62a5d 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/TsFileInsertionEventParser.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/TsFileInsertionEventParser.java @@ -22,9 +22,9 @@ import org.apache.iotdb.commons.audit.IAuditEntity; import org.apache.iotdb.commons.path.PatternTreeMap; import org.apache.iotdb.commons.pipe.agent.task.meta.PipeTaskMeta; -import org.apache.iotdb.commons.pipe.config.PipeConfig; import org.apache.iotdb.commons.pipe.datastructure.pattern.TablePattern; import org.apache.iotdb.commons.pipe.datastructure.pattern.TreePattern; +import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.pipe.event.common.PipeInsertionEvent; import org.apache.iotdb.db.pipe.metric.overview.PipeTsFileToTabletsMetrics; import org.apache.iotdb.db.pipe.resource.PipeDataNodeResourceManager; @@ -106,7 +106,7 @@ protected TsFileInsertionEventParser( this.allocatedMemoryBlockForTablet = PipeDataNodeResourceManager.memory() .forceAllocateForTabletWithRetry( - PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes()); + IoTDBDescriptor.getInstance().getConfig().getPipeDataStructureTabletSizeInBytes()); } /** diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java index 2bd22c8b0bc07..da9d7d00477b9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java @@ -29,6 +29,7 @@ import org.apache.iotdb.commons.pipe.config.PipeConfig; import org.apache.iotdb.commons.pipe.datastructure.pattern.TreePattern; import org.apache.iotdb.db.auth.AuthorityChecker; +import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.pipe.event.common.PipeInsertionEvent; import org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent; import org.apache.iotdb.db.pipe.event.common.tsfile.parser.TsFileInsertionEventParser; @@ -135,7 +136,7 @@ public TsFileInsertionEventScanParser( this.allocatedMemoryBlockForBatchData = PipeDataNodeResourceManager.memory() .forceAllocateForTabletWithRetry( - PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes()); + IoTDBDescriptor.getInstance().getConfig().getPipeDataStructureTabletSizeInBytes()); this.allocatedMemoryBlockForChunk = PipeDataNodeResourceManager.memory() .forceAllocateForTabletWithRetry(PipeConfig.getInstance().getPipeMaxReaderChunkSize()); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParser.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParser.java index e353163e726ab..af2fd214e4a30 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParser.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParser.java @@ -93,7 +93,7 @@ public TsFileInsertionEventTableParser( .forceAllocateForTabletWithRetry(currentModifications.ramBytesUsed()); long tableSize = Math.min( - PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes(), + IoTDBDescriptor.getInstance().getConfig().getPipeDataStructureTabletSizeInBytes(), IoTDBDescriptor.getInstance().getConfig().getTargetChunkSize()); this.allocatedMemoryBlockForChunk = @@ -107,7 +107,9 @@ public TsFileInsertionEventTableParser( this.allocatedMemoryBlockForTableSchemas = PipeDataNodeResourceManager.memory() .forceAllocateForTabletWithRetry( - PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes()); + IoTDBDescriptor.getInstance() + .getConfig() + .getPipeDataStructureTabletSizeInBytes()); this.startTime = startTime; this.endTime = endTime; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java index 79d49440d67a0..833bd3577eb68 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeightUtil.java @@ -20,6 +20,7 @@ package org.apache.iotdb.db.pipe.resource.memory; import org.apache.iotdb.commons.pipe.config.PipeConfig; +import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.pipe.event.common.row.PipeRow; import org.apache.iotdb.db.utils.MemUtils; @@ -195,7 +196,7 @@ private static Pair calculateTabletRowCountAndMemoryBySize( // Here we estimate the max use of int sizeLimit = Math.min( - PipeConfig.getInstance().getPipeDataStructureTabletSizeInBytes(), + IoTDBDescriptor.getInstance().getConfig().getPipeDataStructureTabletSizeInBytes(), (int) (inputNum * rowBytesUsed * 1.2)); int rowNumber = 8 * (sizeLimit - 100) / (8 * rowBytesUsed + schemaCount); From c62143d1b42176d049272d717707fd90326c2cbf Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 9 Apr 2026 17:28:10 +0800 Subject: [PATCH 5/8] fix --- .../pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java index 0e8ff890b82fb..03835e7743bf3 100644 --- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java @@ -589,7 +589,8 @@ public void testTransferMods() { Collections.singleton("5,")); TestUtils.executeNonQueries( - senderEnv, Arrays.asList("drop pipe test_history", "drop pipe test_realtime")); + senderEnv, + Arrays.asList("drop pipe if exists test_history", "drop pipe if exists test_realtime")); TestUtils.executeNonQuery(receiverEnv, "drop database root.**"); From d8fade39c87921dcca2994eccc4b1b56c3c52ff7 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 9 Apr 2026 18:08:57 +0800 Subject: [PATCH 6/8] fix --- .../pipe/receiver/IoTDBFileReceiver.java | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java index ff8c8dbd293d8..66dd0e9c97e3e 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java @@ -145,11 +145,11 @@ protected TPipeTransferResp handleTransferHandshakeV1(final PipeTransferHandshak } catch (Exception e) { PipeLogger.log( LOGGER::warn, + e, "Receiver id = %s: Failed to delete original receiver file dir %s, because %s.", receiverId.get(), receiverFileDirWithIdSuffix.get().getPath(), - e.getMessage(), - e); + e.getMessage()); } } else { if (LOGGER.isDebugEnabled()) { @@ -183,9 +183,9 @@ protected TPipeTransferResp handleTransferHandshakeV1(final PipeTransferHandshak } catch (Exception e) { PipeLogger.log( LOGGER::warn, + e, "Receiver id = %s: Failed to create pipe receiver file folder because all disks of folders are full.", - receiverId.get(), - e); + receiverId.get()); return new TPipeTransferResp(StatusUtils.getStatus(TSStatusCode.DISK_SPACE_INSUFFICIENT)); } @@ -524,11 +524,11 @@ private void closeCurrentWritingFileWriter(final boolean fsyncBeforeClose) { } catch (final Exception e) { PipeLogger.log( LOGGER::warn, + e, "Receiver id = %s: Failed to close current writing file writer %s, because %s.", receiverId.get(), writingFile == null ? "null" : writingFile.getPath(), - e.getMessage(), - e); + e.getMessage()); } writingFileWriter = null; } else { @@ -563,11 +563,11 @@ private void deleteFile(final File file) { } catch (final Exception e) { PipeLogger.log( LOGGER::warn, + e, "Receiver id = %s: Failed to delete original writing file %s, because %s.", receiverId.get(), file.getPath(), - e.getMessage(), - e); + e.getMessage()); } } else { if (LOGGER.isDebugEnabled()) { @@ -648,11 +648,11 @@ protected final TPipeTransferResp handleTransferFileSealV1(final PipeTransferFil } catch (final Exception e) { PipeLogger.log( LOGGER::warn, + e, "Receiver id = %s: Failed to seal file %s from req %s.", receiverId.get(), writingFile, - req, - e); + req); return new TPipeTransferResp( RpcUtils.getStatus( TSStatusCode.PIPE_TRANSFER_FILE_ERROR, @@ -745,11 +745,11 @@ protected final TPipeTransferResp handleTransferFileSealV2(final PipeTransferFil } catch (final Exception e) { PipeLogger.log( LOGGER::warn, + e, "Receiver id = %s: Failed to seal file %s from req %s.", receiverId.get(), files, - req, - e); + req); return new TPipeTransferResp( RpcUtils.getStatus( TSStatusCode.PIPE_TRANSFER_FILE_ERROR, From af03119cdc93048859ce26ecdb40f56b888981a4 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 9 Apr 2026 18:13:04 +0800 Subject: [PATCH 7/8] sptls --- .../apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java index 66dd0e9c97e3e..d094c40dea580 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java @@ -563,7 +563,7 @@ private void deleteFile(final File file) { } catch (final Exception e) { PipeLogger.log( LOGGER::warn, - e, + e, "Receiver id = %s: Failed to delete original writing file %s, because %s.", receiverId.get(), file.getPath(), From f5f264655c14d823a0a39d9de27f48fda6175f4f Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Fri, 10 Apr 2026 10:02:47 +0800 Subject: [PATCH 8/8] Update CommonConfig.java --- .../main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java index 0f6dbe989e1f9..754ea976a5825 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java @@ -219,7 +219,7 @@ public class CommonConfig { private int pipeDataStructureTabletRowSize = 2048; - // 128MB + // 60MB private int pipeDataStructureTabletSizeInBytes = 60 * 1024 * 1024; private double pipeDataStructureTabletMemoryBlockAllocationRejectThreshold = 0.3; private double pipeDataStructureTsFileMemoryBlockAllocationRejectThreshold = 0.3;