[iotdb] branch QueryDebug updated: add deletion related logs (#2841)

[jackietien]

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

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


The following commit(s) were added to refs/heads/QueryDebug by this push:
     new cd88edb  add deletion related logs (#2841)
cd88edb is described below

commit cd88edbfd5ad2442c693d26756b18bfb004fb8d7
Author: wshao08 <59866276+wsha...@users.noreply.github.com>
AuthorDate: Mon Mar 15 13:59:30 2021 +0800

    add deletion related logs (#2841)
---
 .../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java    | 2 ++
 .../java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java | 4 ++++
 2 files changed, 6 insertions(+)

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 4161201..52eca9d 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
@@ -1601,6 +1601,8 @@ public class StorageGroupProcessor {
       tsFileResource.getModFile().write(deletion);
       // remember to close mod file
       tsFileResource.getModFile().close();
+      logger.info("[Deletion] Deletion with path:{}, time:{}-{} written into 
mods file.",
+              deletion.getPath(), deletion.getStartTime(), 
deletion.getEndTime());
 
       tsFileResource.updatePlanIndexes(planIndex);
 
diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
index d14f257..20b924f 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
@@ -393,11 +393,15 @@ public class TsFileProcessor {
         for (PartialPath device : devicePaths) {
           workMemTable.delete(deletion.getPath(), device, 
deletion.getStartTime(),
               deletion.getEndTime());
+          logger.info("[Deletion] Delete in-memory data with deletion path: 
{}, time:{}-{}.",
+                  deletion.getPath(), deletion.getStartTime(), 
deletion.getEndTime());
         }
       }
       // flushing memTables are immutable, only record this deletion in these 
memTables for query
       for (IMemTable memTable : flushingMemTables) {
         memTable.delete(deletion);
+        logger.info("[Deletion] delete flushing memtable with deletion path: 
{}, time:{}-{}",
+                deletion.getPath(), deletion.getStartTime(), 
deletion.getEndTime());
       }
     } finally {
       flushQueryLock.writeLock().unlock();