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 2c424adf09a CN Pipe
new d660e282ef3 Merge branch 'compation-log' of
https://github.com/apache/iotdb into log_local
2c424adf09a is described below
commit 2c424adf09a5be3766b9dd6b72a601073ac177a6
Author: Caideyipi <[email protected]>
AuthorDate: Fri Jun 20 11:54:43 2025 +0800
CN Pipe
---
.../src/assembly/resources/conf/logback-confignode.xml | 18 ++++++++++++++++++
.../pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java | 2 +-
.../manager/pipe/agent/task/PipeConfigNodeSubtask.java | 2 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 2 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +--
.../connector/protocol/IoTDBConfigRegionConnector.java | 2 +-
.../pipe/coordinator/plugin/PipePluginCoordinator.java | 2 +-
.../pipe/coordinator/runtime/PipeMetaSyncer.java | 2 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 2 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 2 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 2 +-
.../pipe/coordinator/task/PipeTaskCoordinatorLock.java | 2 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 2 +-
.../pipe/extractor/ConfigRegionListeningQueue.java | 2 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 3 +--
.../overview/PipeConfigNodeRemainingTimeMetrics.java | 3 +--
.../pipe/metric/overview/PipeProcedureMetrics.java | 2 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 3 +--
.../metric/sink/PipeConfigRegionConnectorMetrics.java | 3 +--
.../source/PipeConfigRegionExtractorMetrics.java | 3 +--
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +-
.../PipeConfigNodeCopiedFileDirStartupCleaner.java | 3 +--
22 files changed, 39 insertions(+), 28 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 0322b49ebdd..c0fc8728220 100644
--- a/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
+++ b/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
@@ -100,6 +100,21 @@
<level>INFO</level>
</filter>
</appender>
+ <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="PipeLog">
+ <file>${IOTDB_HOME}/logs/pipe.log</file>
+ <rollingPolicy
class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+
<fileNamePattern>${IOTDB_HOME}/logs/pipe-%d{yyyyMMdd}.log.gz</fileNamePattern>
+ <maxHistory>30</maxHistory>
+ </rollingPolicy>
+ <append>true</append>
+ <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+ <pattern>%d [%t] %-5p %C{25}:%L - %m %n</pattern>
+ <charset>utf-8</charset>
+ </encoder>
+ <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
+ <level>DEBUG</level>
+ </filter>
+ </appender>
<root level="info">
<appender-ref ref="FILEDEBUG"/>
<appender-ref ref="FILEWARN"/>
@@ -109,4 +124,7 @@
</root>
<logger level="info" name="org.apache.iotdb.confignode"/>
<logger level="info" name="org.apache.ratis"/>
+ <logger level="debug" name="PipeLog" additivity="false">
+ <appender-ref ref="PipeLog"/>
+ </logger>
</configuration>
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
index b89e401d5c7..f8c19b35c20 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java
@@ -41,7 +41,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
public class PipeConfigNodeRuntimeAgent implements IService {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeConfigNodeRuntimeAgent.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private final PipeConfigRegionListener regionListener = new
PipeConfigRegionListener();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtask.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtask.java
index 381769d1df3..43ac6406189 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtask.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtask.java
@@ -49,7 +49,7 @@ import static
org.apache.iotdb.db.protocol.client.ConfigNodeInfo.CONFIG_REGION_I
public class PipeConfigNodeSubtask extends PipeAbstractConnectorSubtask {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeConfigNodeSubtask.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private final String pipeName;
private final PipeTaskMeta pipeTaskMeta;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
index 0e90174a7f2..cffd9753e91 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgent.java
@@ -55,7 +55,7 @@ import java.util.stream.Collectors;
public class PipeConfigNodeTaskAgent extends PipeTaskAgent {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeConfigNodeTaskAgent.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
@Override
protected boolean isShutdown() {
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionAirGapConnector.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionAirGapConnector.java
index c5fdc4765f9..b5b0af80cd1 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionAirGapConnector.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionAirGapConnector.java
@@ -50,8 +50,7 @@ import java.util.Objects;
public class IoTDBConfigRegionAirGapConnector extends IoTDBAirGapConnector {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(IoTDBConfigRegionAirGapConnector.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
@Override
protected byte[] generateHandShakeV1Payload() throws IOException {
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionConnector.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionConnector.java
index 3761f696875..fa6668a570c 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionConnector.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionConnector.java
@@ -54,7 +54,7 @@ import java.util.Objects;
public class IoTDBConfigRegionConnector extends IoTDBSslSyncConnector {
- private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConfigRegionConnector.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
@Override
protected IoTDBSyncClientManager constructClient(
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/plugin/PipePluginCoordinator.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/plugin/PipePluginCoordinator.java
index b26e8ab3ce1..d3fcc85c830 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/plugin/PipePluginCoordinator.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/plugin/PipePluginCoordinator.java
@@ -43,7 +43,7 @@ import java.util.Collections;
public class PipePluginCoordinator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipePluginCoordinator.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private final ConfigManager configManager;
private final PipePluginInfo pipePluginInfo;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeMetaSyncer.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeMetaSyncer.java
index 1df5ac021ca..1b3eab4cf68 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeMetaSyncer.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeMetaSyncer.java
@@ -40,7 +40,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class PipeMetaSyncer {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeMetaSyncer.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final ScheduledExecutorService SYNC_EXECUTOR =
IoTDBThreadPoolFactory.newSingleThreadScheduledExecutor(
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
index e2303fecdea..888696d3afc 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java
@@ -45,7 +45,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class PipeHeartbeatParser {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeHeartbeatParser.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private final ConfigManager configManager;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatScheduler.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatScheduler.java
index 3533b40158d..d2a6cbddcfb 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatScheduler.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatScheduler.java
@@ -43,7 +43,7 @@ import java.util.concurrent.TimeUnit;
public class PipeHeartbeatScheduler {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeHeartbeatScheduler.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final boolean IS_SEPERATED_PIPE_HEARTBEAT_ENABLED =
PipeConfig.getInstance().isSeperatedPipeHeartbeatEnabled();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java
index 100da334d35..8b2d67ca444 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java
@@ -43,7 +43,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class PipeTaskCoordinator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeTaskCoordinator.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private final ConfigManager configManager;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLock.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLock.java
index 535cf022836..cc7d346526d 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLock.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLock.java
@@ -33,7 +33,7 @@ import java.util.concurrent.atomic.AtomicLong;
*/
public class PipeTaskCoordinatorLock {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeTaskCoordinatorLock.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private final BlockingDeque<Long> deque = new LinkedBlockingDeque<>(1);
private final AtomicLong idGenerator = new AtomicLong(0);
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/event/PipeConfigRegionSnapshotEvent.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/event/PipeConfigRegionSnapshotEvent.java
index 1f6f2ff0f94..a7b5ebd71f9 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/event/PipeConfigRegionSnapshotEvent.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/event/PipeConfigRegionSnapshotEvent.java
@@ -51,7 +51,7 @@ import java.util.stream.Collectors;
public class PipeConfigRegionSnapshotEvent extends PipeSnapshotEvent
implements ReferenceTrackableEvent {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeConfigRegionSnapshotEvent.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private String snapshotPath;
// This will only be filled in when the snapshot is a schema info file.
private String templateFilePath;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/ConfigRegionListeningQueue.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/ConfigRegionListeningQueue.java
index 8fe2dce73a8..bdb82d01096 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/ConfigRegionListeningQueue.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/ConfigRegionListeningQueue.java
@@ -55,7 +55,7 @@ import java.util.Objects;
public class ConfigRegionListeningQueue extends AbstractPipeListeningQueue
implements SnapshotProcessor {
- private static final Logger LOGGER =
LoggerFactory.getLogger(ConfigRegionListeningQueue.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final String SNAPSHOT_FILE_NAME =
"pipe_config_region_listening_queue.bin";
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
index 6c9430e3795..dd0a9b9365a 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
@@ -73,8 +73,7 @@ import java.util.stream.Stream;
*/
public class PipeConfigPhysicalPlanPatternParseVisitor
extends ConfigPhysicalPlanVisitor<Optional<ConfigPhysicalPlan>,
IoTDBPipePattern> {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(PipeConfigPhysicalPlanPatternParseVisitor.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
@Override
public Optional<ConfigPhysicalPlan> visitPlan(
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeConfigNodeRemainingTimeMetrics.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeConfigNodeRemainingTimeMetrics.java
index 7cbdc4eecc3..43ab5ad2ecb 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeConfigNodeRemainingTimeMetrics.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeConfigNodeRemainingTimeMetrics.java
@@ -38,8 +38,7 @@ import java.util.concurrent.ConcurrentHashMap;
public class PipeConfigNodeRemainingTimeMetrics implements IMetricSet {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(PipeConfigNodeRemainingTimeMetrics.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
@SuppressWarnings("java:S3077")
private volatile AbstractMetricService metricService;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeProcedureMetrics.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeProcedureMetrics.java
index 102c050c8f2..3e21ed074f0 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeProcedureMetrics.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeProcedureMetrics.java
@@ -37,7 +37,7 @@ import java.util.Map;
public class PipeProcedureMetrics implements IMetricSet {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeProcedureMetrics.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private final Map<String, Timer> timerMap = new HashMap<>();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeTemporaryMetaInCoordinatorMetrics.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeTemporaryMetaInCoordinatorMetrics.java
index 8ebc9d22b3c..a94e7f77bae 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeTemporaryMetaInCoordinatorMetrics.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeTemporaryMetaInCoordinatorMetrics.java
@@ -45,8 +45,7 @@ import java.util.concurrent.ConcurrentHashMap;
* variables from the {@link PipeTemporaryMeta}.
*/
public class PipeTemporaryMetaInCoordinatorMetrics implements IMetricSet {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(PipeTemporaryMetaInCoordinatorMetrics.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
@SuppressWarnings("java:S3077")
private volatile AbstractMetricService metricService;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/sink/PipeConfigRegionConnectorMetrics.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/sink/PipeConfigRegionConnectorMetrics.java
index 85952fbb008..17be15bf526 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/sink/PipeConfigRegionConnectorMetrics.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/sink/PipeConfigRegionConnectorMetrics.java
@@ -38,8 +38,7 @@ import java.util.concurrent.ConcurrentMap;
public class PipeConfigRegionConnectorMetrics implements IMetricSet {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(PipeConfigRegionConnectorMetrics.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
@SuppressWarnings("java:S3077")
private volatile AbstractMetricService metricService;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/source/PipeConfigRegionExtractorMetrics.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/source/PipeConfigRegionExtractorMetrics.java
index aedf3057acc..8f7b27d5f50 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/source/PipeConfigRegionExtractorMetrics.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/source/PipeConfigRegionExtractorMetrics.java
@@ -37,8 +37,7 @@ import java.util.concurrent.ConcurrentHashMap;
public class PipeConfigRegionExtractorMetrics implements IMetricSet {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(PipeConfigRegionExtractorMetrics.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private volatile AbstractMetricService metricService;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java
index 0986e50b31a..d7c444f046e 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java
@@ -96,7 +96,7 @@ import java.util.concurrent.atomic.AtomicInteger;
public class IoTDBConfigNodeReceiver extends IoTDBFileReceiver {
- private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBConfigNodeReceiver.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final SessionManager SESSION_MANAGER =
SessionManager.getInstance();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/PipeConfigNodeCopiedFileDirStartupCleaner.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/PipeConfigNodeCopiedFileDirStartupCleaner.java
index a60d3a7fa65..600cfff6cd0 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/PipeConfigNodeCopiedFileDirStartupCleaner.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/PipeConfigNodeCopiedFileDirStartupCleaner.java
@@ -30,8 +30,7 @@ import java.io.File;
public class PipeConfigNodeCopiedFileDirStartupCleaner {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(PipeConfigNodeCopiedFileDirStartupCleaner.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
/** Delete the snapshot directory of pipe. */
public static void clean() {
