This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch compation-log
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/compation-log by this push:
new eb25f85045f spotless + pipe
eb25f85045f is described below
commit eb25f85045ffc1b95944234e9753abb30a3fbecc
Author: Caideyipi <[email protected]>
AuthorDate: Fri Jun 20 12:23:34 2025 +0800
spotless + pipe
---
.../src/assembly/resources/conf/logback-confignode.xml | 2 +-
.../datanode/src/assembly/resources/conf/logback-datanode.xml | 2 +-
.../java/org/apache/iotdb/db/storageengine/StorageEngine.java | 10 ++++++----
.../db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java | 1 -
.../wal/allocation/AbstractNodeAllocationStrategy.java | 3 +--
.../iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java | 1 -
.../load/active/ActiveLoadFailedMessageHandler.java | 5 ++---
.../storageengine/load/active/ActiveLoadMetricsCollector.java | 2 +-
.../load/active/ActiveLoadScheduledExecutorService.java | 3 +--
.../load/converter/LoadConvertedInsertTabletStatement.java | 3 +--
.../LoadTreeStatementDataTypeConvertExecutionVisitor.java | 3 +--
.../load/memory/LoadTsFileAbstractMemoryBlock.java | 1 +
.../load/memory/LoadTsFileDataCacheMemoryBlock.java | 3 +--
13 files changed, 17 insertions(+), 22 deletions(-)
diff --git
a/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
b/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
index c0fc8728220..4354065caf5 100644
--- a/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
+++ b/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
@@ -101,7 +101,7 @@
</filter>
</appender>
<appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="PipeLog">
- <file>${IOTDB_HOME}/logs/pipe.log</file>
+ <file>${IOTDB_HOME}/logs/pipe_confignode.log</file>
<rollingPolicy
class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${IOTDB_HOME}/logs/pipe-%d{yyyyMMdd}.log.gz</fileNamePattern>
<maxHistory>30</maxHistory>
diff --git
a/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
b/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
index 18aa047a8ad..f044e670b17 100644
--- a/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
+++ b/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
@@ -223,7 +223,7 @@
</filter>
</appender>
<appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="PipeLog">
- <file>${IOTDB_HOME}/logs/pipe.log</file>
+ <file>${IOTDB_HOME}/logs/pipe_datanode.log</file>
<rollingPolicy
class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${IOTDB_HOME}/logs/pipe-%d{yyyyMMdd}.log.gz</fileNamePattern>
<maxHistory>30</maxHistory>
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
index f25e04045aa..162c79aa036 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
@@ -113,10 +113,12 @@ import static
org.apache.iotdb.commons.conf.IoTDBConstant.FILE_NAME_SEPARATOR;
public class StorageEngine implements IService {
private static final Logger OTHER_LOGGER =
LoggerFactory.getLogger(StorageEngine.class);
- private static final Logger WRITE_LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
- private static final Logger READ_LOGGER =
LoggerFactory.getLogger(IoTDBConstant.QUERY_LOGGER_NAME);
- private static final Logger COMPACTION_LOGGER =
LoggerFactory.getLogger(IoTDBConstant.COMPACTION_LOGGER_NAME);
-
+ private static final Logger WRITE_LOGGER =
+ LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
+ private static final Logger READ_LOGGER =
+ LoggerFactory.getLogger(IoTDBConstant.QUERY_LOGGER_NAME);
+ private static final Logger COMPACTION_LOGGER =
+ LoggerFactory.getLogger(IoTDBConstant.COMPACTION_LOGGER_NAME);
private static final IoTDBConfig CONFIG =
IoTDBDescriptor.getInstance().getConfig();
private static final WritingMetrics WRITING_METRICS =
WritingMetrics.getInstance();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
index 142170f174d..b4be6624ca8 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
@@ -21,7 +21,6 @@ package org.apache.iotdb.db.storageengine.dataregion.memtable;
import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.utils.TestOnly;
-import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.exception.query.QueryProcessException;
import org.apache.iotdb.db.queryengine.execution.fragment.QueryContext;
import
org.apache.iotdb.db.storageengine.dataregion.read.reader.chunk.MemChunkLoader;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
index 97c4c7aa68c..845f363a7b4 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
@@ -37,8 +37,7 @@ import java.io.IOException;
import java.util.Arrays;
public abstract class AbstractNodeAllocationStrategy implements
NodeAllocationStrategy {
- private static final Logger logger =
- LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
+ private static final Logger logger =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final CommonConfig commonConfig =
CommonDescriptor.getInstance().getConfig();
// manage wal folders
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
index f0dde4d2b49..5a906382067 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
@@ -20,7 +20,6 @@
package org.apache.iotdb.db.storageengine.dataregion.wal.buffer;
import org.apache.iotdb.commons.conf.IoTDBConstant;
-import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNode;
import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeType;
import
org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.ContinuousSameSearchIndexSeparatorNode;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandler.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandler.java
index 26d15a71c6f..7bd136caeb9 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandler.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandler.java
@@ -20,8 +20,8 @@
package org.apache.iotdb.db.storageengine.load.active;
import org.apache.iotdb.commons.conf.CommonDescriptor;
-
import org.apache.iotdb.commons.conf.IoTDBConstant;
+
import org.apache.tsfile.utils.Pair;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -32,8 +32,7 @@ import java.util.Map;
public class ActiveLoadFailedMessageHandler {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final Map<String, ExceptionMessageHandler>
EXCEPTION_MESSAGE_HANDLER_MAP =
Collections.unmodifiableMap(
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadMetricsCollector.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadMetricsCollector.java
index 62bfb798631..fd421f3fc00 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadMetricsCollector.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadMetricsCollector.java
@@ -20,8 +20,8 @@
package org.apache.iotdb.db.storageengine.load.active;
import org.apache.iotdb.commons.concurrent.ThreadName;
-
import org.apache.iotdb.commons.conf.IoTDBConstant;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadScheduledExecutorService.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadScheduledExecutorService.java
index 79b0713e973..4edb91df450 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadScheduledExecutorService.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadScheduledExecutorService.java
@@ -39,8 +39,7 @@ import java.util.concurrent.TimeUnit;
public abstract class ActiveLoadScheduledExecutorService {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
protected static final IoTDBConfig IOTDB_CONFIG =
IoTDBDescriptor.getInstance().getConfig();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatement.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatement.java
index e7a2b97e49f..ceb7c15456b 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatement.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatement.java
@@ -30,8 +30,7 @@ import org.slf4j.LoggerFactory;
public class LoadConvertedInsertTabletStatement extends
PipeConvertedInsertTabletStatement {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private final boolean shouldConvertOnTypeMismatch;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
index 837c613faa8..1efbc6fe8a7 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
@@ -52,8 +52,7 @@ import static
org.apache.iotdb.db.pipe.resource.memory.PipeMemoryWeightUtil.calc
public class LoadTreeStatementDataTypeConvertExecutionVisitor
extends StatementVisitor<Optional<TSStatus>, Void> {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final long TABLET_BATCH_MEMORY_SIZE_IN_BYTES =
IoTDBDescriptor.getInstance()
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileAbstractMemoryBlock.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileAbstractMemoryBlock.java
index 798e411eabd..60c9eaa7d6c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileAbstractMemoryBlock.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileAbstractMemoryBlock.java
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.storageengine.load.memory;
import org.apache.iotdb.commons.conf.IoTDBConstant;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileDataCacheMemoryBlock.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileDataCacheMemoryBlock.java
index a96b44e45d1..66652fa5bb5 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileDataCacheMemoryBlock.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileDataCacheMemoryBlock.java
@@ -29,8 +29,7 @@ import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
public class LoadTsFileDataCacheMemoryBlock extends
LoadTsFileAbstractMemoryBlock {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final long MINIMUM_MEMORY_SIZE_IN_BYTES = 1024 * 1024L; // 1
MB
private final AtomicLong limitedMemorySizeInBytes;
