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

[ja...@apache.org]

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 <59...@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();