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 cb2f16578f8 subscription / pipe
new 6d0c6d3b121 Merge branch 'compation-log' of
https://github.com/apache/iotdb into log_local
cb2f16578f8 is described below
commit cb2f16578f8cd68909a45656645ae4b95c17cb9d
Author: Caideyipi <[email protected]>
AuthorDate: Fri Jun 20 14:45:54 2025 +0800
subscription / pipe
---
.../src/assembly/resources/conf/logback-confignode.xml | 18 ++++++++++++++++++
.../manager/subscription/SubscriptionCoordinator.java | 2 +-
.../manager/subscription/SubscriptionMetaSyncer.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 3 +--
.../impl/pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../pipe/runtime/PipeHandleLeaderChangeProcedure.java | 3 +--
.../pipe/runtime/PipeHandleMetaChangeProcedure.java | 2 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 2 +-
.../procedure/impl/pipe/task/AlterPipeProcedureV2.java | 2 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 2 +-
.../procedure/impl/pipe/task/DropPipeProcedureV2.java | 2 +-
.../procedure/impl/pipe/task/StartPipeProcedureV2.java | 2 +-
.../procedure/impl/pipe/task/StopPipeProcedureV2.java | 2 +-
.../AbstractOperateSubscriptionProcedure.java | 3 +--
.../consumer/AlterConsumerGroupProcedure.java | 2 +-
.../runtime/ConsumerGroupMetaSyncProcedure.java | 3 +--
.../AbstractOperateSubscriptionAndPipeProcedure.java | 3 +--
.../subscription/CreateSubscriptionProcedure.java | 2 +-
.../subscription/DropSubscriptionProcedure.java | 2 +-
.../impl/subscription/topic/AlterTopicProcedure.java | 2 +-
.../impl/subscription/topic/CreateTopicProcedure.java | 2 +-
.../impl/subscription/topic/DropTopicProcedure.java | 2 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 2 +-
.../src/assembly/resources/conf/logback-datanode.xml | 18 ++++++++++++++++++
.../subscription/agent/SubscriptionAgentLauncher.java | 2 +-
.../db/subscription/agent/SubscriptionBrokerAgent.java | 2 +-
.../subscription/agent/SubscriptionConsumerAgent.java | 2 +-
.../subscription/agent/SubscriptionReceiverAgent.java | 2 +-
.../db/subscription/agent/SubscriptionTopicAgent.java | 2 +-
.../db/subscription/broker/SubscriptionBroker.java | 2 +-
.../broker/SubscriptionPrefetchingQueue.java | 2 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 3 +--
.../broker/SubscriptionPrefetchingTabletQueue.java | 3 +--
.../broker/SubscriptionPrefetchingTsFileQueue.java | 3 +--
.../TsFileDeduplicationBlockingPendingQueue.java | 3 +--
.../iotdb/db/subscription/event/SubscriptionEvent.java | 2 +-
.../event/batch/SubscriptionPipeEventBatch.java | 2 +-
.../event/batch/SubscriptionPipeEventBatches.java | 2 +-
.../event/batch/SubscriptionPipeTabletEventBatch.java | 3 +--
.../event/batch/SubscriptionPipeTsFileEventBatch.java | 3 +--
.../event/cache/SubscriptionPollResponseCache.java | 2 +-
.../response/SubscriptionEventTabletResponse.java | 3 +--
.../response/SubscriptionEventTsFileResponse.java | 3 +--
.../metric/SubscriptionPrefetchingQueueMetrics.java | 3 +--
.../subscription/receiver/SubscriptionReceiverV1.java | 2 +-
.../resource/log/SubscriptionLogStatus.java | 2 +-
.../task/execution/SubscriptionSubtaskExecutor.java | 2 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 2 +-
.../subtask/SubscriptionConnectorSubtaskLifeCycle.java | 3 +--
.../subtask/SubscriptionConnectorSubtaskManager.java | 3 +--
51 files changed, 85 insertions(+), 65 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 5bee5421848..5c03d94d4f7 100644
--- a/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
+++ b/iotdb-core/confignode/src/assembly/resources/conf/logback-confignode.xml
@@ -115,6 +115,21 @@
<level>DEBUG</level>
</filter>
</appender>
+ <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="SubscriptionLog">
+ <file>${IOTDB_HOME}/logs/subscription_confignode.log</file>
+ <rollingPolicy
class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+
<fileNamePattern>${IOTDB_HOME}/logs/subscription-confignode-%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"/>
@@ -127,4 +142,7 @@
<logger level="debug" name="PipeLog" additivity="false">
<appender-ref ref="PipeLog"/>
</logger>
+ <logger level="debug" name="SubscriptionLog" additivity="false">
+ <appender-ref ref="SubscriptionLog"/>
+ </logger>
</configuration>
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinator.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinator.java
index 20dfce44bf2..03ef8a402e3 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinator.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinator.java
@@ -50,7 +50,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class SubscriptionCoordinator {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionCoordinator.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final ConfigManager configManager;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionMetaSyncer.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionMetaSyncer.java
index de49987e13f..1e43c51f70f 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionMetaSyncer.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionMetaSyncer.java
@@ -37,7 +37,7 @@ import java.util.concurrent.TimeUnit;
public class SubscriptionMetaSyncer {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionMetaSyncer.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final ScheduledExecutorService SYNC_EXECUTOR =
IoTDBThreadPoolFactory.newSingleThreadScheduledExecutor(
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java
index e50c7fe9604..b38cb72f310 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java
@@ -75,8 +75,7 @@ import java.util.concurrent.atomic.AtomicReference;
public abstract class AbstractOperatePipeProcedureV2
extends AbstractNodeProcedure<OperatePipeTaskState> {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(AbstractOperatePipeProcedureV2.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final int RETRY_THRESHOLD = 1;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
index 3b20fee4d2b..a92598d51dc 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
@@ -59,7 +59,7 @@ import java.util.Objects;
*/
public class CreatePipePluginProcedure extends
AbstractNodeProcedure<CreatePipePluginState> {
- private static final Logger LOGGER =
LoggerFactory.getLogger(CreatePipePluginProcedure.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final int RETRY_THRESHOLD = 5;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
index ca949576cc1..3bff44352c4 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
@@ -58,7 +58,7 @@ import java.util.concurrent.atomic.AtomicReference;
*/
public class DropPipePluginProcedure extends
AbstractNodeProcedure<DropPipePluginState> {
- private static final Logger LOGGER =
LoggerFactory.getLogger(DropPipePluginProcedure.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final int RETRY_THRESHOLD = 5;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
index f18737e8b7a..1bf4efa427c 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
@@ -45,8 +45,7 @@ import java.util.Objects;
public class PipeHandleLeaderChangeProcedure extends
AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(PipeHandleLeaderChangeProcedure.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private Map<TConsensusGroupId, Pair<Integer, Integer>>
regionGroupToOldAndNewLeaderPairMap =
new HashMap<>();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
index 401859f0a7e..cd9a44f3c6c 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
@@ -45,7 +45,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class PipeHandleMetaChangeProcedure extends
AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeHandleMetaChangeProcedure.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private boolean needWriteConsensusOnConfigNodes = false;
private boolean needPushPipeMetaToDataNodes = false;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeMetaSyncProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeMetaSyncProcedure.java
index c8a734a9e35..a47928d72ba 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeMetaSyncProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeMetaSyncProcedure.java
@@ -47,7 +47,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class PipeMetaSyncProcedure extends AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PipeMetaSyncProcedure.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private static final long MIN_EXECUTION_INTERVAL_MS =
PipeConfig.getInstance().getPipeMetaSyncerSyncIntervalMinutes() * 60 *
1000 / 2;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
index b11c74408a6..775cf985902 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
@@ -54,7 +54,7 @@ import java.util.concurrent.ConcurrentMap;
public class AlterPipeProcedureV2 extends AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
LoggerFactory.getLogger(AlterPipeProcedureV2.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private TAlterPipeReq alterPipeRequest;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
index 813d4ebe69e..1402653c2b7 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
@@ -65,7 +65,7 @@ import static
org.apache.iotdb.commons.pipe.config.constant.PipeExtractorConstan
public class CreatePipeProcedureV2 extends AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
LoggerFactory.getLogger(CreatePipeProcedureV2.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private TCreatePipeReq createPipeRequest;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
index 0c7042caf3f..7f7662a6c69 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
@@ -42,7 +42,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class DropPipeProcedureV2 extends AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
LoggerFactory.getLogger(DropPipeProcedureV2.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private String pipeName;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
index fe36137b35f..3ed83741cbd 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
@@ -41,7 +41,7 @@ import java.util.Objects;
public class StartPipeProcedureV2 extends AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
LoggerFactory.getLogger(StartPipeProcedureV2.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private String pipeName;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
index 5349cc65640..41e225005a6 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
@@ -41,7 +41,7 @@ import java.util.Objects;
public class StopPipeProcedureV2 extends AbstractOperatePipeProcedureV2 {
- private static final Logger LOGGER =
LoggerFactory.getLogger(StopPipeProcedureV2.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger("PipeLog");
private String pipeName;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java
index dcefa8d5f45..43bac8dcaa6 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java
@@ -51,8 +51,7 @@ import java.util.concurrent.atomic.AtomicReference;
public abstract class AbstractOperateSubscriptionProcedure
extends AbstractNodeProcedure<OperateSubscriptionState> {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(AbstractOperateSubscriptionProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final String SKIP_SUBSCRIPTION_PROCEDURE_MESSAGE =
"Skip subscription-related operations and do nothing";
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/AlterConsumerGroupProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/AlterConsumerGroupProcedure.java
index 69017422505..9ea3a04557f 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/AlterConsumerGroupProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/AlterConsumerGroupProcedure.java
@@ -46,7 +46,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class AlterConsumerGroupProcedure extends
AbstractOperateSubscriptionProcedure {
- protected static final Logger LOGGER =
LoggerFactory.getLogger(AlterConsumerGroupProcedure.class);
+ protected static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
protected ConsumerGroupMeta existingConsumerGroupMeta;
protected ConsumerGroupMeta updatedConsumerGroupMeta;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/runtime/ConsumerGroupMetaSyncProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/runtime/ConsumerGroupMetaSyncProcedure.java
index 93eb6c5a5fc..80f27384608 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/runtime/ConsumerGroupMetaSyncProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/runtime/ConsumerGroupMetaSyncProcedure.java
@@ -47,8 +47,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class ConsumerGroupMetaSyncProcedure extends
AbstractOperateSubscriptionProcedure {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(ConsumerGroupMetaSyncProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final long MIN_EXECUTION_INTERVAL_MS =
PipeConfig.getInstance().getPipeMetaSyncerSyncIntervalMinutes() * 60 *
1000 / 2;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/AbstractOperateSubscriptionAndPipeProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/AbstractOperateSubscriptionAndPipeProcedure.java
index 2b420136253..ab7e24a5dcb 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/AbstractOperateSubscriptionAndPipeProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/AbstractOperateSubscriptionAndPipeProcedure.java
@@ -38,8 +38,7 @@ import java.util.concurrent.atomic.AtomicReference;
public abstract class AbstractOperateSubscriptionAndPipeProcedure
extends AbstractOperateSubscriptionProcedure {
- private static final Logger LOGGER =
-
LoggerFactory.getLogger(AbstractOperateSubscriptionAndPipeProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
protected AtomicReference<PipeTaskInfo> pipeTaskInfo;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/CreateSubscriptionProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/CreateSubscriptionProcedure.java
index 4a48ebdd35d..d1417338087 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/CreateSubscriptionProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/CreateSubscriptionProcedure.java
@@ -55,7 +55,7 @@ import java.util.stream.Collectors;
public class CreateSubscriptionProcedure extends
AbstractOperateSubscriptionAndPipeProcedure {
- private static final Logger LOGGER =
LoggerFactory.getLogger(CreateSubscriptionProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private TSubscribeReq subscribeReq;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/DropSubscriptionProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/DropSubscriptionProcedure.java
index 6741a6c1e2a..323e7359b5a 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/DropSubscriptionProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/DropSubscriptionProcedure.java
@@ -54,7 +54,7 @@ import java.util.stream.Collectors;
public class DropSubscriptionProcedure extends
AbstractOperateSubscriptionAndPipeProcedure {
- private static final Logger LOGGER =
LoggerFactory.getLogger(DropSubscriptionProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private TUnsubscribeReq unsubscribeReq;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/AlterTopicProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/AlterTopicProcedure.java
index 4faa2cfa0c1..4f989157eba 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/AlterTopicProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/AlterTopicProcedure.java
@@ -45,7 +45,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class AlterTopicProcedure extends AbstractOperateSubscriptionProcedure {
- private static final Logger LOGGER =
LoggerFactory.getLogger(AlterTopicProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private TopicMeta updatedTopicMeta;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java
index c27205290a8..62e9bd81305 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java
@@ -46,7 +46,7 @@ import java.util.Objects;
public class CreateTopicProcedure extends AbstractOperateSubscriptionProcedure
{
- private static final Logger LOGGER =
LoggerFactory.getLogger(CreateTopicProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private TCreateTopicReq createTopicReq;
private TopicMeta topicMeta;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/DropTopicProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/DropTopicProcedure.java
index 363e5716ee8..9d3ddbb0361 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/DropTopicProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/DropTopicProcedure.java
@@ -42,7 +42,7 @@ import java.util.Objects;
public class DropTopicProcedure extends AbstractOperateSubscriptionProcedure {
- private static final Logger LOGGER =
LoggerFactory.getLogger(DropTopicProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private String topicName;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/runtime/TopicMetaSyncProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/runtime/TopicMetaSyncProcedure.java
index 27919bbcb9e..8970667929f 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/runtime/TopicMetaSyncProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/runtime/TopicMetaSyncProcedure.java
@@ -47,7 +47,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class TopicMetaSyncProcedure extends
AbstractOperateSubscriptionProcedure {
- private static final Logger LOGGER =
LoggerFactory.getLogger(TopicMetaSyncProcedure.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final long MIN_EXECUTION_INTERVAL_MS =
PipeConfig.getInstance().getPipeMetaSyncerSyncIntervalMinutes() * 60 *
1000 / 2;
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 8ce3f64a078..2595523325c 100644
--- a/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
+++ b/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
@@ -237,6 +237,21 @@
<level>DEBUG</level>
</filter>
</appender>
+ <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="SubscriptionLog">
+ <file>${IOTDB_HOME}/logs/subscription_datanode.log</file>
+ <rollingPolicy
class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+
<fileNamePattern>${IOTDB_HOME}/logs/subscription-datanode-%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>
<appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="EXPLAIN_ANALYZE">
<file>${IOTDB_HOME}/logs/log_explain_analyze.log</file>
<rollingPolicy
class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
@@ -288,6 +303,9 @@
<logger level="debug" name="PipeLog" additivity="false">
<appender-ref ref="PipeLog"/>
</logger>
+ <logger level="debug" name="SubscriptionLog" additivity="false">
+ <appender-ref ref="SubscriptionLog"/>
+ </logger>
<logger level="debug" name="WriteLog" additivity="false">
<appender-ref ref="WriteLog"/>
</logger>
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionAgentLauncher.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionAgentLauncher.java
index d83996cda47..3e70983ae0f 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionAgentLauncher.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionAgentLauncher.java
@@ -43,7 +43,7 @@ import java.util.stream.Collectors;
class SubscriptionAgentLauncher {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionAgentLauncher.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
// For fail-over
public static final int MAX_RETRY_TIMES = 5;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.java
index f1ee9f8867b..fc204e9a2cc 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.java
@@ -39,7 +39,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
public class SubscriptionBrokerAgent {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionBrokerAgent.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final Map<String, SubscriptionBroker>
consumerGroupIdToSubscriptionBroker =
new ConcurrentHashMap<>();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
index fee23cf6af4..e06d1404076 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
@@ -33,7 +33,7 @@ import java.util.Set;
public class SubscriptionConsumerAgent {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionConsumerAgent.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final ConsumerGroupMetaKeeper consumerGroupMetaKeeper;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgent.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgent.java
index 0eb32e21f5d..fe4542458e0 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgent.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgent.java
@@ -40,7 +40,7 @@ import java.util.function.Supplier;
public class SubscriptionReceiverAgent {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionReceiverAgent.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final ThreadLocal<SubscriptionReceiver> receiverThreadLocal = new
ThreadLocal<>();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgent.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgent.java
index 4c2bf5d0217..bdfee9fe3c8 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgent.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgent.java
@@ -35,7 +35,7 @@ import java.util.stream.Collectors;
public class SubscriptionTopicAgent {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionTopicAgent.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final TopicMetaKeeper topicMetaKeeper;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionBroker.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionBroker.java
index 1223672810d..59f49613445 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionBroker.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionBroker.java
@@ -57,7 +57,7 @@ import static
org.apache.iotdb.rpc.subscription.payload.poll.SubscriptionCommitC
public class SubscriptionBroker {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionBroker.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final String brokerId; // consumer group id
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueue.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueue.java
index 0f638e20d80..85dabee61d6 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueue.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueue.java
@@ -59,7 +59,7 @@ import static
org.apache.iotdb.rpc.subscription.payload.poll.SubscriptionCommitC
public abstract class SubscriptionPrefetchingQueue {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionPrefetchingQueue.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final String brokerId; // consumer group id
private final String topicName;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueueStates.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueueStates.java
index 70eacd2eaaa..2a6eb4cb735 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueueStates.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueueStates.java
@@ -39,8 +39,7 @@ import static
com.google.common.base.MoreObjects.toStringHelper;
*/
public class SubscriptionPrefetchingQueueStates {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionPrefetchingQueueStates.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final double EPSILON = 1e-6;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTabletQueue.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTabletQueue.java
index 4b7a166b922..dca5f6e7c7c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTabletQueue.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTabletQueue.java
@@ -41,8 +41,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class SubscriptionPrefetchingTabletQueue extends
SubscriptionPrefetchingQueue {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionPrefetchingTabletQueue.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
public SubscriptionPrefetchingTabletQueue(
final String brokerId,
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTsFileQueue.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTsFileQueue.java
index 98156972353..9df2555d62a 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTsFileQueue.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTsFileQueue.java
@@ -43,8 +43,7 @@ import java.util.concurrent.atomic.AtomicReference;
public class SubscriptionPrefetchingTsFileQueue extends
SubscriptionPrefetchingQueue {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionPrefetchingTsFileQueue.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
public SubscriptionPrefetchingTsFileQueue(
final String brokerId,
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueue.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueue.java
index e4a3a545a58..36609fa43b9 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueue.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueue.java
@@ -36,8 +36,7 @@ import java.util.concurrent.TimeUnit;
public class TsFileDeduplicationBlockingPendingQueue extends
SubscriptionBlockingPendingQueue {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(TsFileDeduplicationBlockingPendingQueue.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final Cache<Integer, Boolean>
hashCodeToIsGeneratedByHistoricalExtractor;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionEvent.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionEvent.java
index 90bc9c603d5..55ecbc3f61a 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionEvent.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionEvent.java
@@ -50,7 +50,7 @@ import static
org.apache.iotdb.rpc.subscription.payload.poll.SubscriptionCommitC
public class SubscriptionEvent implements Comparable<SubscriptionEvent> {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionEvent.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final long INVALID_TIMESTAMP = -1;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatch.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatch.java
index fe1b280f16c..bffef12c6ec 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatch.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatch.java
@@ -36,7 +36,7 @@ import java.util.function.Consumer;
public abstract class SubscriptionPipeEventBatch {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionPipeEventBatch.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final int regionId;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatches.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatches.java
index c20dffcd5e9..82b26c37c80 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatches.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeEventBatches.java
@@ -38,7 +38,7 @@ import java.util.function.Consumer;
public class SubscriptionPipeEventBatches {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionPipeEventBatches.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
protected final SubscriptionPrefetchingQueue prefetchingQueue;
protected final int maxDelayInMs;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
index bc705287993..1d9dde70943 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
@@ -48,8 +48,7 @@ import java.util.concurrent.atomic.AtomicLong;
public class SubscriptionPipeTabletEventBatch extends
SubscriptionPipeEventBatch
implements Iterator<List<Tablet>> {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionPipeTabletEventBatch.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private long firstEventProcessingTime = Long.MIN_VALUE;
private long totalBufferSize = 0;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
index 47be439912b..a8f7a24cee9 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatch.java
@@ -38,8 +38,7 @@ import java.util.concurrent.atomic.AtomicInteger;
public class SubscriptionPipeTsFileEventBatch extends
SubscriptionPipeEventBatch {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionPipeTsFileEventBatch.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final PipeTabletEventTsFileBatch batch;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCache.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCache.java
index 55848c47c01..dee425b1a24 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCache.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCache.java
@@ -42,7 +42,7 @@ import java.util.Optional;
*/
public class SubscriptionPollResponseCache {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionPollResponseCache.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final AtomicDouble memoryUsageCheatFactor = new AtomicDouble(1);
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTabletResponse.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTabletResponse.java
index c6150536f21..93eff770054 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTabletResponse.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTabletResponse.java
@@ -54,8 +54,7 @@ import java.util.concurrent.atomic.AtomicInteger;
*/
public class SubscriptionEventTabletResponse extends
SubscriptionEventExtendableResponse {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionEventTabletResponse.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final long READ_TABLET_BUFFER_SIZE =
SubscriptionConfig.getInstance().getSubscriptionReadTabletBufferSize();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTsFileResponse.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTsFileResponse.java
index 5cc7f40cd79..47e3ef0e4b7 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTsFileResponse.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTsFileResponse.java
@@ -54,8 +54,7 @@ import java.util.Optional;
*/
public class SubscriptionEventTsFileResponse extends
SubscriptionEventExtendableResponse {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionEventTsFileResponse.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final long READ_FILE_BUFFER_SIZE =
SubscriptionConfig.getInstance().getSubscriptionReadFileBufferSize();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/metric/SubscriptionPrefetchingQueueMetrics.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/metric/SubscriptionPrefetchingQueueMetrics.java
index 4e712fb2972..e8a397c8566 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/metric/SubscriptionPrefetchingQueueMetrics.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/metric/SubscriptionPrefetchingQueueMetrics.java
@@ -39,8 +39,7 @@ import java.util.concurrent.ConcurrentHashMap;
public class SubscriptionPrefetchingQueueMetrics implements IMetricSet {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionPrefetchingQueueMetrics.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private volatile AbstractMetricService metricService;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1.java
index 7a7459d0ab2..83868f3869b 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1.java
@@ -87,7 +87,7 @@ import java.util.stream.Collectors;
public class SubscriptionReceiverV1 implements SubscriptionReceiver {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionReceiverV1.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final double POLL_PAYLOAD_SIZE_EXCEED_THRESHOLD = 0.9;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogStatus.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogStatus.java
index 0daae1dc937..9105e36eeca 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogStatus.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogStatus.java
@@ -43,7 +43,7 @@ class SubscriptionLogStatus {
private final Cache<Pair<String, String>, AtomicLong> lastReportTimestamps;
public SubscriptionLogStatus(final Class<?> logClass) {
- this.logger = LoggerFactory.getLogger(logClass);
+ this.logger = LoggerFactory.getLogger("SubscriptionLog");
this.lastReportTimestamps =
Caffeine.newBuilder()
.expireAfterAccess(
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/SubscriptionSubtaskExecutor.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/SubscriptionSubtaskExecutor.java
index f473a56a447..711073e8f39 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/SubscriptionSubtaskExecutor.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/SubscriptionSubtaskExecutor.java
@@ -37,7 +37,7 @@ import java.util.concurrent.atomic.AtomicLong;
public class SubscriptionSubtaskExecutor extends PipeConnectorSubtaskExecutor {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionSubtaskExecutor.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final AtomicLong submittedReceiverSubtasks = new AtomicLong(0);
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtask.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtask.java
index bf1155b4b58..8186c4580b6 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtask.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtask.java
@@ -32,7 +32,7 @@ import org.slf4j.LoggerFactory;
public class SubscriptionConnectorSubtask extends PipeConnectorSubtask {
- private static final Logger LOGGER =
LoggerFactory.getLogger(SubscriptionConnectorSubtask.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private final String topicName;
private final String consumerGroupId;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskLifeCycle.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskLifeCycle.java
index 359690fa272..64f05144f7c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskLifeCycle.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskLifeCycle.java
@@ -31,8 +31,7 @@ import org.slf4j.LoggerFactory;
public class SubscriptionConnectorSubtaskLifeCycle extends
PipeConnectorSubtaskLifeCycle {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionConnectorSubtaskLifeCycle.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
public SubscriptionConnectorSubtaskLifeCycle(
final PipeConnectorSubtaskExecutor executor, //
SubscriptionSubtaskExecutor
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskManager.java
index c443ffd7306..f56c4bd0e41 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskManager.java
@@ -52,8 +52,7 @@ import static
org.apache.iotdb.commons.pipe.agent.plugin.builtin.BuiltinPipePlug
public class SubscriptionConnectorSubtaskManager {
- private static final Logger LOGGER =
- LoggerFactory.getLogger(SubscriptionConnectorSubtaskManager.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger("SubscriptionLog");
private static final String FAILED_TO_DEREGISTER_EXCEPTION_MESSAGE =
"Failed to deregister PipeConnectorSubtask. No such subtask: ";
