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 2020/04/26 06:16:07 UTC
[incubator-iotdb] branch fix_tablet_last updated (effcddc ->
1a5314f)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch fix_tablet_last
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from effcddc try to fix last cache
new 01c3bae remove unused log
new 1a5314f remove unused 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:
.../org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
[incubator-iotdb] 02/02: remove unused log
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch fix_tablet_last
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 1a5314f71bb25b7346aaa6bf5432833695c4f04e
Author: qiaojialin <64...@qq.com>
AuthorDate: Sun Apr 26 14:15:46 2020 +0800
remove unused log
---
.../org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 930365f..c644a81 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -601,7 +601,7 @@ public class StorageGroupProcessor {
}
long globalLatestFlushedTime = globalLatestFlushedTimeForEachDevice.getOrDefault(
insertTabletPlan.getDeviceId(), Long.MIN_VALUE);
- tryToUpdateBatchInsertLastCache(insertTabletPlan, end -1, globalLatestFlushedTime);
+ tryToUpdateBatchInsertLastCache(insertTabletPlan, end - 1, globalLatestFlushedTime);
// check memtable size and may async try to flush the work memtable
if (tsFileProcessor.shouldFlush()) {
[incubator-iotdb] 01/02: remove unused log
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch fix_tablet_last
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 01c3bae6dde4adc66da7fe20d953674998a74177
Author: qiaojialin <64...@qq.com>
AuthorDate: Sun Apr 26 14:15:32 2020 +0800
remove unused log
---
.../org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 74bfa63..930365f 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -575,7 +575,6 @@ public class StorageGroupProcessor {
return;
}
- logger.info("@+++<<<: current batch start {} end {}", start, end);
TsFileProcessor tsFileProcessor = getOrCreateTsFileProcessor(timePartitionId, sequence);
if (tsFileProcessor == null) {
for (int i = start; i < end; i++) {