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 <[email protected]> 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)); }
