This is an automated email from the ASF dual-hosted git repository. marklau99 pushed a commit to branch compressed-wal in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f5b8fcd94866738d0d72c88feeff83445b8b04cf Author: Liu Xuxin <[email protected]> AuthorDate: Thu Jan 25 17:40:02 2024 +0800 remove useless log --- .../apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java | 5 ----- .../iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java | 1 - 2 files changed, 6 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java index 991a44a3700..ec0b3c74b09 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java @@ -67,11 +67,6 @@ public abstract class LogWriter implements ILogWriter { ByteBuffer compressedBuffer = ByteBuffer.allocateDirect(compressor.getMaxBytesForCompression(buffer.limit())); compressor.compress(buffer, compressedBuffer); - logger.error( - "compressed size: {}, original size: {}, compression ratio is {}", - compressedBuffer.position(), - bufferSize, - (double) bufferSize / compressedBuffer.position()); buffer = compressedBuffer; bufferSize = buffer.position(); buffer.flip(); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java index 34354beecb7..e6a235c9729 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java @@ -59,7 +59,6 @@ public class WALInputStream extends InputStream implements AutoCloseable { private void loadNextSegment() throws IOException { headerBuffer.clear(); - logger.error("channel's offset is {}", channel.position()); if (channel.read(headerBuffer) != Integer.BYTES + 1) { throw new IOException("Unexpected end of file"); }
