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/11 13:40:00 UTC
[incubator-iotdb] branch feature_async_close_tsfile updated
(5db92ac -> 96d0cce)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch feature_async_close_tsfile
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 5db92ac fix groupSizeInByte config
new e73afbf fix capacity bug
new 96d0cce add memtablepool log
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
[incubator-iotdb] 02/02: add memtablepool log
Posted by qi...@apache.org.
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
commit 96d0ccec10e5a3c61f35e20817a141d2bddfc527
Author: qiaojialin <64...@qq.com>
AuthorDate: Tue Jun 11 21:39:47 2019 +0800
add memtablepool log
---
.../src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
index 47411c7..3bbb5d1 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
@@ -22,8 +22,10 @@ public class MemTablePool {
synchronized (emptyMemTables) {
if (emptyMemTables.isEmpty() && size < capacity) {
size++;
+ LOGGER.info("generated a new memtable, system memtable size: {}, stack size: {}", size, emptyMemTables.size());
return new PrimitiveMemTable();
} else if (!emptyMemTables.isEmpty()){
+ LOGGER.info("system memtable size: {}, stack size: {}, then get a memtable from stack", size, emptyMemTables.size());
return emptyMemTables.pop();
}
}
[incubator-iotdb] 01/02: fix capacity bug
Posted by qi...@apache.org.
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
commit e73afbfdf3463e16b41fc108f7f2e127ea89cf33
Author: qiaojialin <64...@qq.com>
AuthorDate: Tue Jun 11 21:35:45 2019 +0800
fix capacity bug
---
.../main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
index 1fb4a64..47411c7 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTablePool.java
@@ -8,7 +8,8 @@ public class MemTablePool {
private static final Logger LOGGER = LoggerFactory.getLogger(MemTablePool.class);
private Stack<IMemTable> emptyMemTables;
- private int capacity = 10;
+ // >= number of storage group * 2
+ private int capacity = 23;
private int size = 0;
private static final MemTablePool INSTANCE = new MemTablePool();