[iotdb] 01/01: Add more log

[ja...@apache.org]

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

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

commit ca212dd6a17a8eb267668dedb062e06639c2a5c9
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Jun 8 10:11:59 2022 +0800

    Add more log
---
 .../apache/iotdb/db/mpp/execution/datatransfer/SourceHandle.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandle.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandle.java
index 6e3a847cdd..09cf2d848a 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandle.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandle.java
@@ -116,6 +116,7 @@ public class SourceHandle implements ISourceHandle {
 
     TsBlock tsBlock;
     tsBlock = sequenceIdToTsBlock.remove(currSequenceId);
+    logger.info("{}: receive TsBlock. block size is: {}", this, tsBlock.getRetainedSizeInBytes());
     currSequenceId += 1;
     bufferRetainedSizeInBytes -= tsBlock.getRetainedSizeInBytes();
     localMemoryManager
@@ -205,10 +206,11 @@ public class SourceHandle implements ISourceHandle {
 
   synchronized void updatePendingDataBlockInfo(int startSequenceId, List<Long> dataBlockSizes) {
     logger.info(
-        "{}: receive newDataBlockEvent. [{}, {})",
+        "{}: receive newDataBlockEvent. [{}, {}), block size is: {}",
         this,
         startSequenceId,
-        startSequenceId + dataBlockSizes.size());
+        startSequenceId + dataBlockSizes.size(),
+        dataBlockSizes);
     for (int i = 0; i < dataBlockSizes.size(); i++) {
       sequenceIdToDataBlockSize.put(i + startSequenceId, dataBlockSizes.get(i));
     }