You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/07/09 15:30:51 UTC
(iotdb) 01/01: better avg series number flush
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 <hh...@outlook.com>
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