This is an automated email from the ASF dual-hosted git repository.
shuwenwei 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 d132ad963ba modify load log
d132ad963ba is described below
commit d132ad963badd87f0e73a02018d1b7199905a270
Author: shuwenwei <[email protected]>
AuthorDate: Fri Jun 20 11:58:07 2025 +0800
modify load log
---
.../iotdb/db/storageengine/dataregion/HashLastFlushTimeMap.java | 3 ++-
.../iotdb/db/storageengine/dataregion/flush/CompressionRatio.java | 3 ++-
.../apache/iotdb/db/storageengine/dataregion/flush/FlushManager.java | 3 ++-
.../storageengine/dataregion/flush/pool/FlushSubTaskPoolManager.java | 3 ++-
.../db/storageengine/dataregion/flush/pool/FlushTaskPoolManager.java | 3 ++-
.../iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java | 4 +++-
.../org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java | 2 +-
.../iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java | 3 ++-
.../db/storageengine/load/active/ActiveLoadFailedMessageHandler.java | 3 ++-
.../db/storageengine/load/active/ActiveLoadMetricsCollector.java | 3 ++-
.../storageengine/load/active/ActiveLoadScheduledExecutorService.java | 3 ++-
.../iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java | 3 ++-
.../load/converter/LoadConvertedInsertTabletStatement.java | 3 ++-
.../converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java | 3 ++-
.../db/storageengine/load/converter/LoadTsFileDataTypeConverter.java | 3 ++-
.../org/apache/iotdb/db/storageengine/load/disk/MinIOSelector.java | 2 +-
.../db/storageengine/load/memory/LoadTsFileAbstractMemoryBlock.java | 3 ++-
.../db/storageengine/load/memory/LoadTsFileDataCacheMemoryBlock.java | 3 ++-
.../iotdb/db/storageengine/load/memory/LoadTsFileMemoryBlock.java | 3 ++-
.../iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java | 3 ++-
.../db/storageengine/load/metrics/ActiveLoadingFilesMetricsSet.java | 3 ++-
.../apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java | 3 ++-
22 files changed, 43 insertions(+), 22 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/HashLastFlushTimeMap.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/HashLastFlushTimeMap.java
index 3f0abfd3e24..ce6d03c541d 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/HashLastFlushTimeMap.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/HashLastFlushTimeMap.java
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.storageengine.dataregion;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.storageengine.StorageEngine;
import org.apache.tsfile.file.metadata.IDeviceID;
@@ -30,7 +31,7 @@ import java.util.concurrent.ConcurrentHashMap;
public class HashLastFlushTimeMap implements ILastFlushTimeMap {
- private static final Logger logger =
LoggerFactory.getLogger(HashLastFlushTimeMap.class);
+ private static final Logger logger =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
long LONG_SIZE = 24;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java
index 6253717386e..0f73ed7fc24 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java
@@ -18,6 +18,7 @@
*/
package org.apache.iotdb.db.storageengine.dataregion.flush;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.file.SystemFileFactory;
import org.apache.iotdb.commons.utils.TestOnly;
import org.apache.iotdb.db.conf.IoTDBConfig;
@@ -46,7 +47,7 @@ import java.util.concurrent.atomic.AtomicLong;
*/
public class CompressionRatio {
- private static final Logger LOGGER =
LoggerFactory.getLogger(CompressionRatio.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final IoTDBConfig CONFIG =
IoTDBDescriptor.getInstance().getConfig();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/FlushManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/FlushManager.java
index 9e526e8267b..148259d9210 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/FlushManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/FlushManager.java
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.storageengine.dataregion.flush;
import org.apache.iotdb.commons.concurrent.WrappedRunnable;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.exception.StartupException;
import org.apache.iotdb.commons.service.IService;
import org.apache.iotdb.commons.service.JMXService;
@@ -38,7 +39,7 @@ import java.util.concurrent.Future;
@SuppressWarnings("squid:S6548")
public class FlushManager implements FlushManagerMBean, IService {
- private static final Logger LOGGER =
LoggerFactory.getLogger(FlushManager.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private FlushTaskPoolManager flushPool = FlushTaskPoolManager.getInstance();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushSubTaskPoolManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushSubTaskPoolManager.java
index 1cc75e2039c..0541e969bf6 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushSubTaskPoolManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushSubTaskPoolManager.java
@@ -21,6 +21,7 @@ package
org.apache.iotdb.db.storageengine.dataregion.flush.pool;
import org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory;
import org.apache.iotdb.commons.concurrent.ThreadName;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.storageengine.rescon.memory.AbstractPoolManager;
import org.slf4j.Logger;
@@ -29,7 +30,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings("squid:S6548")
public class FlushSubTaskPoolManager extends AbstractPoolManager {
- private static final Logger LOGGER =
LoggerFactory.getLogger(FlushSubTaskPoolManager.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private FlushSubTaskPoolManager() {
this.pool =
IoTDBThreadPoolFactory.newCachedThreadPool(ThreadName.FLUSH_SUB_TASK.getName());
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushTaskPoolManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushTaskPoolManager.java
index 65bb88d65b6..16491740e85 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushTaskPoolManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/pool/FlushTaskPoolManager.java
@@ -20,6 +20,7 @@ package
org.apache.iotdb.db.storageengine.dataregion.flush.pool;
import org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory;
import org.apache.iotdb.commons.concurrent.ThreadName;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.storageengine.rescon.memory.AbstractPoolManager;
@@ -29,7 +30,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings("squid:S6548")
public class FlushTaskPoolManager extends AbstractPoolManager {
- private static final Logger LOGGER =
LoggerFactory.getLogger(FlushTaskPoolManager.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private FlushTaskPoolManager() {
int threadCnt =
IoTDBDescriptor.getInstance().getConfig().getFlushThreadCount();
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 22fac1604ca..142170f174d 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
@@ -19,7 +19,9 @@
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;
@@ -62,7 +64,7 @@ public class ReadOnlyMemChunk {
private TSDataType dataType;
- private static final Logger logger =
LoggerFactory.getLogger(ReadOnlyMemChunk.class);
+ private static final Logger logger =
LoggerFactory.getLogger(IoTDBConstant.QUERY_LOGGER_NAME);
protected IChunkMetadata cachedMetaData;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
index fe8a5806113..0a93f39b7b9 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
@@ -83,7 +83,7 @@ import java.util.stream.Stream;
*/
public class LoadTsFileManager {
- private static final Logger LOGGER =
LoggerFactory.getLogger(LoadTsFileManager.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final IoTDBConfig CONFIG =
IoTDBDescriptor.getInstance().getConfig();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
index 34bb392dc28..b2944b8709c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScanner.java
@@ -21,6 +21,7 @@ package org.apache.iotdb.db.storageengine.load.active;
import org.apache.iotdb.commons.concurrent.ThreadName;
import org.apache.iotdb.commons.conf.CommonDescriptor;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import
org.apache.iotdb.db.storageengine.load.metrics.ActiveLoadingFilesNumberMetricsSet;
import
org.apache.iotdb.db.storageengine.load.metrics.ActiveLoadingFilesSizeMetricsSet;
@@ -46,7 +47,7 @@ import java.util.stream.Stream;
public class ActiveLoadDirScanner extends ActiveLoadScheduledExecutorService {
- private static final Logger LOGGER =
LoggerFactory.getLogger(ActiveLoadDirScanner.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final String RESOURCE = ".resource";
private static final String MODS = ".mods";
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 be66e591d5d..26d15a71c6f 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
@@ -21,6 +21,7 @@ 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,7 +33,7 @@ import java.util.Map;
public class ActiveLoadFailedMessageHandler {
private static final Logger LOGGER =
- LoggerFactory.getLogger(ActiveLoadFailedMessageHandler.class);
+ 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 de40378a105..62bfb798631 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
@@ -21,12 +21,13 @@ 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;
public class ActiveLoadMetricsCollector extends
ActiveLoadScheduledExecutorService {
- private static final Logger LOGGER =
LoggerFactory.getLogger(ActiveLoadMetricsCollector.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private final ActiveLoadTsFileLoader activeLoadTsFileLoader;
private final ActiveLoadDirScanner activeLoadDirScanner;
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 610918e5a13..79b0713e973 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
@@ -23,6 +23,7 @@ import
org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory;
import org.apache.iotdb.commons.concurrent.ThreadName;
import org.apache.iotdb.commons.concurrent.WrappedRunnable;
import org.apache.iotdb.commons.concurrent.threadpool.ScheduledExecutorUtil;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
@@ -39,7 +40,7 @@ import java.util.concurrent.TimeUnit;
public abstract class ActiveLoadScheduledExecutorService {
private static final Logger LOGGER =
- LoggerFactory.getLogger(ActiveLoadScheduledExecutorService.class);
+ 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/active/ActiveLoadTsFileLoader.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
index 65665f5e3d4..bd6ee481b98 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
@@ -24,6 +24,7 @@ import org.apache.iotdb.commons.concurrent.IoTThreadFactory;
import org.apache.iotdb.commons.concurrent.ThreadName;
import
org.apache.iotdb.commons.concurrent.threadpool.WrappedThreadPoolExecutor;
import org.apache.iotdb.commons.conf.CommonDescriptor;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.utils.RetryUtils;
import org.apache.iotdb.db.auth.AuthorityChecker;
import org.apache.iotdb.db.conf.IoTDBConfig;
@@ -63,7 +64,7 @@ import java.util.concurrent.locks.LockSupport;
public class ActiveLoadTsFileLoader {
- private static final Logger LOGGER =
LoggerFactory.getLogger(ActiveLoadTsFileLoader.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private 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 97a71dbb94b..e7a2b97e49f 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
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.storageengine.load.converter;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.pipe.receiver.transform.converter.ArrayConverter;
import
org.apache.iotdb.db.pipe.receiver.transform.statement.PipeConvertedInsertTabletStatement;
import
org.apache.iotdb.db.queryengine.plan.statement.crud.InsertTabletStatement;
@@ -30,7 +31,7 @@ import org.slf4j.LoggerFactory;
public class LoadConvertedInsertTabletStatement extends
PipeConvertedInsertTabletStatement {
private static final Logger LOGGER =
- LoggerFactory.getLogger(LoadConvertedInsertTabletStatement.class);
+ 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 cb147f9c286..837c613faa8 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
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.storageengine.load.converter;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBPipePattern;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import
org.apache.iotdb.db.pipe.connector.payload.evolvable.request.PipeTransferTabletRawReq;
@@ -52,7 +53,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(LoadTreeStatementDataTypeConvertExecutionVisitor.class);
+ 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/converter/LoadTsFileDataTypeConverter.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileDataTypeConverter.java
index ee2a8fe2547..0653f1144ec 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileDataTypeConverter.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileDataTypeConverter.java
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.storageengine.load.converter;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.protocol.session.SessionManager;
import org.apache.iotdb.db.queryengine.plan.Coordinator;
@@ -37,7 +38,7 @@ import java.util.Optional;
public class LoadTsFileDataTypeConverter {
- private static final Logger LOGGER =
LoggerFactory.getLogger(LoadTsFileDataTypeConverter.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final SessionManager SESSION_MANAGER =
SessionManager.getInstance();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/MinIOSelector.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/MinIOSelector.java
index f6fac586700..5cd6968f47b 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/MinIOSelector.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/MinIOSelector.java
@@ -38,7 +38,7 @@ import java.util.Optional;
public class MinIOSelector extends InheritSystemMultiDisksStrategySelector {
- private static final Logger logger =
LoggerFactory.getLogger(MinIOSelector.class);
+ private static final Logger logger =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final IoTDBConfig config =
IoTDBDescriptor.getInstance().getConfig();
private final Map<String, String> rootDisks2DataDirsMapForLoad;
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 f0df55a9f63..798e411eabd 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
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.storageengine.load.memory;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -26,7 +27,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
public abstract class LoadTsFileAbstractMemoryBlock implements AutoCloseable {
- private static final Logger LOGGER =
LoggerFactory.getLogger(LoadTsFileAbstractMemoryBlock.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
protected static final LoadTsFileMemoryManager MEMORY_MANAGER =
LoadTsFileMemoryManager.getInstance();
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 9932b37df02..a96b44e45d1 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
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.storageengine.load.memory;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.exception.load.LoadRuntimeOutOfMemoryException;
import org.slf4j.Logger;
@@ -29,7 +30,7 @@ import java.util.concurrent.atomic.AtomicLong;
public class LoadTsFileDataCacheMemoryBlock extends
LoadTsFileAbstractMemoryBlock {
private static final Logger LOGGER =
- LoggerFactory.getLogger(LoadTsFileDataCacheMemoryBlock.class);
+ LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final long MINIMUM_MEMORY_SIZE_IN_BYTES = 1024 * 1024L; // 1
MB
private final AtomicLong limitedMemorySizeInBytes;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryBlock.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryBlock.java
index 608a305d8f0..c499df042cd 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryBlock.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryBlock.java
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.storageengine.load.memory;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.service.metric.MetricService;
import org.apache.iotdb.commons.service.metric.enums.Metric;
import org.apache.iotdb.commons.service.metric.enums.Tag;
@@ -31,7 +32,7 @@ import org.slf4j.LoggerFactory;
import java.util.concurrent.atomic.AtomicLong;
public class LoadTsFileMemoryBlock extends LoadTsFileAbstractMemoryBlock {
- private static final Logger LOGGER =
LoggerFactory.getLogger(LoadTsFileMemoryBlock.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private final long totalMemorySizeInBytes;
private final AtomicLong memoryUsageInBytes;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
index 417d09c1103..dc0568b5276 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryManager.java
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.storageengine.load.memory;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.exception.load.LoadRuntimeOutOfMemoryException;
@@ -31,7 +32,7 @@ import java.util.concurrent.atomic.AtomicLong;
public class LoadTsFileMemoryManager {
- private static final Logger LOGGER =
LoggerFactory.getLogger(LoadTsFileMemoryManager.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private static final IoTDBConfig CONFIG =
IoTDBDescriptor.getInstance().getConfig();
private static final LocalExecutionPlanner QUERY_ENGINE_MEMORY_MANAGER =
LocalExecutionPlanner.getInstance();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/ActiveLoadingFilesMetricsSet.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/ActiveLoadingFilesMetricsSet.java
index f93e8fc9299..b831d13bcd4 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/ActiveLoadingFilesMetricsSet.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/ActiveLoadingFilesMetricsSet.java
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.storageengine.load.metrics;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.service.metric.enums.Tag;
import org.apache.iotdb.metrics.AbstractMetricService;
import org.apache.iotdb.metrics.impl.DoNothingMetricManager;
@@ -39,7 +40,7 @@ import java.util.concurrent.atomic.AtomicReference;
public abstract class ActiveLoadingFilesMetricsSet implements IMetricSet {
- private static final Logger LOGGER =
LoggerFactory.getLogger(ActiveLoadingFilesMetricsSet.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
protected static final String FAILED_PREFIX = "failed - ";
protected static final String PENDING_PREFIX = "pending - ";
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java
index 1a16440db8d..aa8f96b17d0 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.storageengine.load.splitter;
import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
+import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.commons.utils.TimePartitionUtils;
import org.apache.iotdb.db.exception.load.LoadFileException;
import org.apache.iotdb.db.storageengine.dataregion.modification.Deletion;
@@ -63,7 +64,7 @@ import java.util.Set;
import java.util.TreeMap;
public class TsFileSplitter {
- private static final Logger logger =
LoggerFactory.getLogger(TsFileSplitter.class);
+ private static final Logger logger =
LoggerFactory.getLogger(IoTDBConstant.WRITE_LOGGER_NAME);
private final File tsFile;
private final TsFileDataConsumer consumer;
