[iotdb] 01/01: Change the way of calculating vector avg points

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch VectorTest
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 2e46631c3a88c2f479a95a6de2acaf30e04fb4ad
Author: JackieTien97 <jackiet...@foxmail.com>
AuthorDate: Wed Sep 15 21:34:30 2021 +0800

    Change the way of calculating vector avg points
---
 .../java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
index 984ce32..9652c08 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
@@ -53,7 +53,7 @@ public abstract class AbstractMemTable implements IMemTable {
   protected boolean disableMemControl = true;
 
   private boolean shouldFlush = false;
-  private int avgSeriesPointNumThreshold =
+  private final int avgSeriesPointNumThreshold =
       
IoTDBDescriptor.getInstance().getConfig().getAvgSeriesPointNumberThreshold();
   /** memory size of data points, including TEXT values */
   private long memSize = 0;
@@ -112,7 +112,8 @@ public abstract class AbstractMemTable implements IMemTable 
{
         schema.getMeasurementId(),
         k -> {
           seriesNumber++;
-          totalPointsNumThreshold += avgSeriesPointNumThreshold;
+          totalPointsNumThreshold +=
+              ((long) avgSeriesPointNumThreshold * 
schema.getMeasurementCount());
           return genMemSeries(schema);
         });
   }