This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch better_avg_serives_point_number in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit aafe5d7de6f496ca11f9b943a3ade462c3b9c96e Author: HTHou <[email protected]> AuthorDate: Tue Jul 9 22:16:17 2024 +0800 better avg series number flush --- .../java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java index 4092db7d442..0c34253d0e5 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java @@ -19,6 +19,7 @@ package org.apache.iotdb.db.utils.datastructure; +import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.storageengine.dataregion.wal.buffer.IWALByteBufferView; import org.apache.iotdb.db.storageengine.dataregion.wal.utils.WALWriteUtils; import org.apache.iotdb.db.storageengine.rescon.memory.PrimitiveArrayManager; @@ -699,7 +700,8 @@ public abstract class AlignedTVList extends TVList { @Override public boolean reachMaxChunkSizeThreshold() { - return reachMaxChunkSizeFlag; + return reachMaxChunkSizeFlag + || rowCount >= IoTDBDescriptor.getInstance().getConfig().getAvgSeriesPointNumberThreshold(); } @SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity warning
