This is an automated email from the ASF dual-hosted git repository. marklau99 pushed a commit to branch wal-compress-formal-branch in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b15d61b208367e1e35faf709695f052c2da5a1fd Author: Liu Xuxin <[email protected]> AuthorDate: Tue May 7 16:04:25 2024 +0800 fix compilation problem --- .../java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java | 2 +- .../apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java | 5 ++--- .../iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java | 4 ++-- 3 files changed, 5 insertions(+), 6 deletions(-) diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java index b3f06cd6347..86c514a48b3 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java @@ -811,7 +811,7 @@ public class IoTConsensusServerImpl { } public boolean needBlockWrite() { - return false; + return consensusReqReader.getTotalSize() > config.getReplication().getWalThrottleThreshold(); } public boolean unblockWrite() { 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 4e5d6239b32..95bf594dcc3 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 @@ -22,9 +22,9 @@ package org.apache.iotdb.db.storageengine.dataregion.wal.io; import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.storageengine.dataregion.wal.buffer.WALEntry; import org.apache.iotdb.db.storageengine.dataregion.wal.checkpoint.Checkpoint; -import org.apache.iotdb.tsfile.compress.ICompressor; -import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType; +import org.apache.tsfile.compress.ICompressor; +import org.apache.tsfile.file.metadata.enums.CompressionType; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -57,7 +57,6 @@ public abstract class LogWriter implements ILogWriter { this.logStream = new FileOutputStream(logFile, true); this.logChannel = this.logStream.getChannel(); if (IoTDBDescriptor.getInstance().getConfig().isEnableWALCompression()) { - logger.info("Enable WAL compression with gzip"); compressedByteBuffer = ByteBuffer.allocate( compressor.getMaxBytesForCompression( 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 8e742b3cb1b..f75119590fc 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 @@ -19,9 +19,9 @@ package org.apache.iotdb.db.storageengine.dataregion.wal.io; import org.apache.iotdb.db.conf.IoTDBDescriptor; -import org.apache.iotdb.tsfile.compress.IUnCompressor; -import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType; +import org.apache.tsfile.compress.IUnCompressor; +import org.apache.tsfile.file.metadata.enums.CompressionType; import org.slf4j.Logger; import org.slf4j.LoggerFactory;
