You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/03/03 03:03:10 UTC

[iotdb] branch DMB updated: delete useless code

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

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


The following commit(s) were added to refs/heads/DMB by this push:
     new 83bf6cf  delete useless code
83bf6cf is described below

commit 83bf6cf82d1b2d0f1063fd5f02a577234c651bec
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Thu Mar 3 11:02:25 2022 +0800

    delete useless code
---
 .../src/main/java/org/apache/iotdb/tsfile/file/header/PageHeader.java   | 2 +-
 tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java | 2 --
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/file/header/PageHeader.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/file/header/PageHeader.java
index bfbbaaf..178a0a5 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/file/header/PageHeader.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/file/header/PageHeader.java
@@ -31,7 +31,7 @@ import java.nio.ByteBuffer;
 public class PageHeader {
 
   private int uncompressedSize;
-  public int compressedSize;
+  private int compressedSize;
   private Statistics statistics;
   private boolean modified;
 
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java
index 696d799..afa41c5 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java
@@ -247,9 +247,7 @@ public class PageWriter {
         channel.write(pageData);
       }
     } else {
-      int previousPosition = pageBuffer.size();
       pageBuffer.write(compressedBytes, 0, compressedSize);
-      if (pageBuffer.size() - previousPosition == compressedSize) {}
     }
     logger.trace("start to flush a page data into buffer, buffer position {} ", pageBuffer.size());
     return sizeWithoutStatistic;