You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2019/06/29 03:18:25 UTC
[incubator-iotdb] branch feature_async_close_tsfile updated: change
chunkbufferpool capacity to 2208000 and change add tvlist size log
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch feature_async_close_tsfile
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/feature_async_close_tsfile by this push:
new c7cac3d change chunkbufferpool capacity to 2208000 and change add tvlist size log
c7cac3d is described below
commit c7cac3dfcf344f904a3ec73173ca2c4769d93849
Author: qiaojialin <64...@qq.com>
AuthorDate: Sat Jun 29 11:18:12 2019 +0800
change chunkbufferpool capacity to 2208000 and change add tvlist size log
---
.../main/java/org/apache/iotdb/db/engine/memtable/ChunkBufferPool.java | 3 +--
.../java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java | 3 +++
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/ChunkBufferPool.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/ChunkBufferPool.java
index 4b371e4..2539187 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/ChunkBufferPool.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/ChunkBufferPool.java
@@ -40,8 +40,7 @@ public class ChunkBufferPool {
/**
* the number of required FlushTasks is no more than {@linkplain MemTablePool}.
*/
- private static final int capacity = IoTDBDescriptor.getInstance().getConfig()
- .getMemtableNumber();
+ private static final int capacity = 2208000;
private int size = 0;
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java
index 6ef25a7..4ac786b 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java
@@ -82,6 +82,9 @@ public class MemTableFlushTaskV2 {
IWritableMemChunk series = memTable.getMemTableMap().get(deviceId).get(measurementId);
MeasurementSchema desc = fileSchema.getMeasurementSchema(measurementId);
TVList tvList = series.getSortedTVList();
+ if (tvList.size() > 500) {
+ LOGGER.info("TVList size: {}", tvList.size());
+ }
sortTime += System.currentTimeMillis() - startTime;
encodingTaskQueue.add(new Pair<>(tvList, desc));
}