You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ej...@apache.org on 2020/12/09 12:00:30 UTC
[iotdb] branch dev_sliding_mem_table updated: fix v1
This is an automated email from the ASF dual-hosted git repository.
ejttianyu pushed a commit to branch dev_sliding_mem_table
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev_sliding_mem_table by this push:
new 76ebcb8 fix v1
76ebcb8 is described below
commit 76ebcb885f89fcf47cec4ed9a47138fe020eddb5
Author: EJTTianyu <16...@qq.com>
AuthorDate: Wed Dec 9 19:59:59 2020 +0800
fix v1
---
.../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 d094ad9..3fb6dab 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
@@ -916,7 +916,7 @@ public class StorageGroupProcessor {
*/
private boolean isInsertToFlushingMemTable(long timePartitionId, InsertRowPlan insertRowPlan){
return flushingLatestTimeForEachDevice.get(timePartitionId).
- getOrDefault(insertRowPlan.getDeviceId().getFullPath(), Long.MIN_VALUE) > insertRowPlan.getTime();
+ getOrDefault(insertRowPlan.getDeviceId().getFullPath(), Long.MIN_VALUE) >= insertRowPlan.getTime();
}
private void tryToUpdateInsertLastCache(InsertRowPlan plan, Long latestFlushedTime) {