This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch rel/1.2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/1.2 by this push:
new b3788fe97c2 Pipe: fix some minor concurrent issues & collect pipe's
logs into a separate file (#10990) (#10994)
b3788fe97c2 is described below
commit b3788fe97c2c85b354d472481b8fca6d761c5975
Author: Steve Yurong Su <[email protected]>
AuthorDate: Tue Aug 29 20:47:15 2023 +0800
Pipe: fix some minor concurrent issues & collect pipe's logs into a
separate file (#10990) (#10994)
* Pipe: fix some minor concurrent issues
* Logback: seperate pipe's logs
* enabled -> enable
* Update IoTDBConfig.java
(cherry picked from commit 1357cede80d67a8ecc0d8db75f629efd00d1f69d)
---
.../assembly/resources/conf/logback-datanode.xml | 40 +++++++++++-----------
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 3 +-
.../config/constant/PipeConnectorConstant.java | 4 +--
.../db/pipe/connector/protocol/IoTDBConnector.java | 7 ++--
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 ++
.../realtime/epoch/TsFileEpochManager.java | 6 ++--
.../dataregion/memtable/TsFileProcessor.java | 3 +-
.../src/test/resources/datanode1conf/logback.xml | 40 +++++++++++-----------
.../src/test/resources/datanode2conf/logback.xml | 40 +++++++++++-----------
.../src/test/resources/datanode3conf/logback.xml | 40 +++++++++++-----------
10 files changed, 94 insertions(+), 91 deletions(-)
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 4f7373e1c2a..9194c596230 100644
--- a/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
+++ b/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml
@@ -163,23 +163,6 @@
<level>INFO</level>
</filter>
</appender>
- <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="SYNC">
- <file>${IOTDB_HOME}/logs/log_datanode_sync.log</file>
- <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
-
<fileNamePattern>${IOTDB_HOME}/logs/log-datanode-sync-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
- <maxFileSize>10MB</maxFileSize>
- <maxHistory>168</maxHistory>
- <totalSizeCap>512MB</totalSizeCap>
- </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>INFO</level>
- </filter>
- </appender>
<appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="AUDIT">
<file>${IOTDB_HOME}/logs/log_datanode_audit.log</file>
<rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
@@ -265,6 +248,23 @@
<level>INFO</level>
</filter>
</appender>
+ <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="PIPE">
+ <file>${IOTDB_HOME}/logs/log_datanode_pipe.log</file>
+ <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+
<fileNamePattern>${IOTDB_HOME}/logs/log-datanode-pipe-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
+ <maxFileSize>10MB</maxFileSize>
+ <maxHistory>168</maxHistory>
+ <totalSizeCap>512MB</totalSizeCap>
+ </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>INFO</level>
+ </filter>
+ </appender>
<root level="info">
<appender-ref ref="FILETRACE"/>
<appender-ref ref="FILEDEBUG"/>
@@ -280,9 +280,6 @@
<logger level="info" name="org.apache.iotdb.db.cost.statistic">
<appender-ref ref="FILE_COST_MEASURE"/>
</logger>
- <logger level="info" name="org.apache.iotdb.db.sync">
- <appender-ref ref="SYNC"/>
- </logger>
<logger level="info" name="IoTDB_AUDIT_LOGGER">
<appender-ref ref="AUDIT"/>
</logger>
@@ -299,4 +296,7 @@
<logger level="info" name="COMPACTION">
<appender-ref ref="COMPACTION"/>
</logger>
+ <logger level="info" name="org.apache.iotdb.db.pipe">
+ <appender-ref ref="PIPE"/>
+ </logger>
</configuration>
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index bf4c8b56fe8..586a5f2b3c1 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -559,7 +559,8 @@ public class IoTDBConfig {
private long allocateMemoryForTimePartitionInfo =
allocateMemoryForStorageEngine * 8 / 10 / 20;
/** Memory allocated proportion for wal pipe cache */
- private long allocateMemoryForWALPipeCache = allocateMemoryForConsensus / 10;
+ private long allocateMemoryForWALPipeCache =
+ Math.min(allocateMemoryForConsensus / 2, 3 *
getWalFileSizeThresholdInByte());
/**
* If true, we will estimate each query's possible memory footprint before
executing it and deny
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeConnectorConstant.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeConnectorConstant.java
index 2a5b8e0a47a..a55bbbe4716 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeConnectorConstant.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeConnectorConstant.java
@@ -29,8 +29,8 @@ public class PipeConnectorConstant {
public static final String CONNECTOR_IOTDB_PORT_KEY = "connector.port";
public static final String CONNECTOR_IOTDB_NODE_URLS_KEY =
"connector.node-urls";
- public static final String CONNECTOR_IOTDB_BATCH_MODE_ENABLED_KEY =
"connector.batch.enabled";
- public static final boolean CONNECTOR_IOTDB_BATCH_MODE_ENABLED_DEFAULT_VALUE
= true;
+ public static final String CONNECTOR_IOTDB_BATCH_MODE_ENABLE_KEY =
"connector.batch.enable";
+ public static final boolean CONNECTOR_IOTDB_BATCH_MODE_ENABLE_DEFAULT_VALUE
= true;
public static final String CONNECTOR_IOTDB_BATCH_DELAY_KEY =
"connector.batch.max-delay-seconds";
public static final int CONNECTOR_IOTDB_BATCH_DELAY_DEFAULT_VALUE = 1;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/IoTDBConnector.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/IoTDBConnector.java
index 8de5706a958..1ca5db5ba15 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/IoTDBConnector.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/IoTDBConnector.java
@@ -35,8 +35,8 @@ import java.util.HashSet;
import java.util.List;
import java.util.Set;
-import static
org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_BATCH_MODE_ENABLED_DEFAULT_VALUE;
-import static
org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_BATCH_MODE_ENABLED_KEY;
+import static
org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_BATCH_MODE_ENABLE_DEFAULT_VALUE;
+import static
org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_BATCH_MODE_ENABLE_KEY;
import static
org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_IP_KEY;
import static
org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_NODE_URLS_KEY;
import static
org.apache.iotdb.db.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_PORT_KEY;
@@ -87,8 +87,7 @@ public abstract class IoTDBConnector implements PipeConnector
{
isTabletBatchModeEnabled =
parameters.getBooleanOrDefault(
- CONNECTOR_IOTDB_BATCH_MODE_ENABLED_KEY,
- CONNECTOR_IOTDB_BATCH_MODE_ENABLED_DEFAULT_VALUE);
+ CONNECTOR_IOTDB_BATCH_MODE_ENABLE_KEY,
CONNECTOR_IOTDB_BATCH_MODE_ENABLE_DEFAULT_VALUE);
LOGGER.info("IoTDBConnector isTabletBatchModeEnabled: {}",
isTabletBatchModeEnabled);
}
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
index 051e6d0437c..d1d1adf1d4e 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java
@@ -89,6 +89,8 @@ public class PipeTsFileInsertionEvent extends EnrichedEvent
implements TsFileIns
});
}
}
+ // check again after register close listener in case TsFile is closed
during the process
+ isClosed.set(resource.isClosed());
}
public void waitForTsFileClose() throws InterruptedException {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/realtime/epoch/TsFileEpochManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/realtime/epoch/TsFileEpochManager.java
index cb94b725d10..cfa57760985 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/realtime/epoch/TsFileEpochManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/realtime/epoch/TsFileEpochManager.java
@@ -29,8 +29,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Collections;
-import java.util.HashMap;
-import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
import java.util.stream.Collectors;
public class TsFileEpochManager {
@@ -39,7 +39,7 @@ public class TsFileEpochManager {
private static final String[] EMPTY_MEASUREMENT_ARRAY = new String[0];
- private final Map<String, TsFileEpoch> filePath2Epoch = new HashMap<>();
+ private final ConcurrentMap<String, TsFileEpoch> filePath2Epoch = new
ConcurrentHashMap<>();
public PipeRealtimeEvent bindPipeTsFileInsertionEvent(
PipeTsFileInsertionEvent event, TsFileResource resource) {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
index 45e755debb3..3cd09e73e92 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
@@ -84,6 +84,7 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentLinkedDeque;
+import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
@@ -161,7 +162,7 @@ public class TsFileProcessor {
"{}: {} get flushQueryLock write lock released";
/** close file listener. */
- private final List<CloseFileListener> closeFileListeners = new ArrayList<>();
+ private final List<CloseFileListener> closeFileListeners = new
CopyOnWriteArrayList<>();
/** flush file listener. */
private final List<FlushListener> flushListeners = new ArrayList<>();
diff --git a/iotdb-core/datanode/src/test/resources/datanode1conf/logback.xml
b/iotdb-core/datanode/src/test/resources/datanode1conf/logback.xml
index fc779b7716b..0317acebcd5 100644
--- a/iotdb-core/datanode/src/test/resources/datanode1conf/logback.xml
+++ b/iotdb-core/datanode/src/test/resources/datanode1conf/logback.xml
@@ -163,23 +163,6 @@
<level>INFO</level>
</filter>
</appender>
- <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="SYNC">
- <file>${IOTDB_HOME}/logs/log_sync.log</file>
- <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
-
<fileNamePattern>${IOTDB_HOME}/logs/log-sync-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
- <maxFileSize>10MB</maxFileSize>
- <maxHistory>168</maxHistory>
- <totalSizeCap>512MB</totalSizeCap>
- </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>INFO</level>
- </filter>
- </appender>
<appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="AUDIT">
<file>${IOTDB_HOME}/logs/log_audit.log</file>
<rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
@@ -265,6 +248,23 @@
<level>INFO</level>
</filter>
</appender>
+ <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="PIPE">
+ <file>${IOTDB_HOME}/logs/log_datanode_pipe.log</file>
+ <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+
<fileNamePattern>${IOTDB_HOME}/logs/log-datanode-pipe-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
+ <maxFileSize>10MB</maxFileSize>
+ <maxHistory>168</maxHistory>
+ <totalSizeCap>512MB</totalSizeCap>
+ </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>INFO</level>
+ </filter>
+ </appender>
<root level="info">
<appender-ref ref="FILETRACE"/>
<appender-ref ref="FILEDEBUG"/>
@@ -280,9 +280,6 @@
<logger level="info" name="org.apache.iotdb.db.cost.statistic">
<appender-ref ref="FILE_COST_MEASURE"/>
</logger>
- <logger level="info" name="org.apache.iotdb.db.sync">
- <appender-ref ref="SYNC"/>
- </logger>
<logger level="info" name="IoTDB_AUDIT_LOGGER">
<appender-ref ref="AUDIT"/>
</logger>
@@ -299,4 +296,7 @@
<logger level="info" name="COMPACTION">
<appender-ref ref="COMPACTION"/>
</logger>
+ <logger level="info" name="org.apache.iotdb.db.pipe">
+ <appender-ref ref="PIPE"/>
+ </logger>
</configuration>
diff --git a/iotdb-core/datanode/src/test/resources/datanode2conf/logback.xml
b/iotdb-core/datanode/src/test/resources/datanode2conf/logback.xml
index fc779b7716b..0317acebcd5 100644
--- a/iotdb-core/datanode/src/test/resources/datanode2conf/logback.xml
+++ b/iotdb-core/datanode/src/test/resources/datanode2conf/logback.xml
@@ -163,23 +163,6 @@
<level>INFO</level>
</filter>
</appender>
- <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="SYNC">
- <file>${IOTDB_HOME}/logs/log_sync.log</file>
- <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
-
<fileNamePattern>${IOTDB_HOME}/logs/log-sync-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
- <maxFileSize>10MB</maxFileSize>
- <maxHistory>168</maxHistory>
- <totalSizeCap>512MB</totalSizeCap>
- </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>INFO</level>
- </filter>
- </appender>
<appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="AUDIT">
<file>${IOTDB_HOME}/logs/log_audit.log</file>
<rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
@@ -265,6 +248,23 @@
<level>INFO</level>
</filter>
</appender>
+ <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="PIPE">
+ <file>${IOTDB_HOME}/logs/log_datanode_pipe.log</file>
+ <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+
<fileNamePattern>${IOTDB_HOME}/logs/log-datanode-pipe-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
+ <maxFileSize>10MB</maxFileSize>
+ <maxHistory>168</maxHistory>
+ <totalSizeCap>512MB</totalSizeCap>
+ </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>INFO</level>
+ </filter>
+ </appender>
<root level="info">
<appender-ref ref="FILETRACE"/>
<appender-ref ref="FILEDEBUG"/>
@@ -280,9 +280,6 @@
<logger level="info" name="org.apache.iotdb.db.cost.statistic">
<appender-ref ref="FILE_COST_MEASURE"/>
</logger>
- <logger level="info" name="org.apache.iotdb.db.sync">
- <appender-ref ref="SYNC"/>
- </logger>
<logger level="info" name="IoTDB_AUDIT_LOGGER">
<appender-ref ref="AUDIT"/>
</logger>
@@ -299,4 +296,7 @@
<logger level="info" name="COMPACTION">
<appender-ref ref="COMPACTION"/>
</logger>
+ <logger level="info" name="org.apache.iotdb.db.pipe">
+ <appender-ref ref="PIPE"/>
+ </logger>
</configuration>
diff --git a/iotdb-core/datanode/src/test/resources/datanode3conf/logback.xml
b/iotdb-core/datanode/src/test/resources/datanode3conf/logback.xml
index fc779b7716b..0317acebcd5 100644
--- a/iotdb-core/datanode/src/test/resources/datanode3conf/logback.xml
+++ b/iotdb-core/datanode/src/test/resources/datanode3conf/logback.xml
@@ -163,23 +163,6 @@
<level>INFO</level>
</filter>
</appender>
- <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="SYNC">
- <file>${IOTDB_HOME}/logs/log_sync.log</file>
- <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
-
<fileNamePattern>${IOTDB_HOME}/logs/log-sync-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
- <maxFileSize>10MB</maxFileSize>
- <maxHistory>168</maxHistory>
- <totalSizeCap>512MB</totalSizeCap>
- </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>INFO</level>
- </filter>
- </appender>
<appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="AUDIT">
<file>${IOTDB_HOME}/logs/log_audit.log</file>
<rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
@@ -265,6 +248,23 @@
<level>INFO</level>
</filter>
</appender>
+ <appender class="ch.qos.logback.core.rolling.RollingFileAppender"
name="PIPE">
+ <file>${IOTDB_HOME}/logs/log_datanode_pipe.log</file>
+ <rollingPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+
<fileNamePattern>${IOTDB_HOME}/logs/log-datanode-pipe-%d{yyyyMMdd}.%i.log.gz</fileNamePattern>
+ <maxFileSize>10MB</maxFileSize>
+ <maxHistory>168</maxHistory>
+ <totalSizeCap>512MB</totalSizeCap>
+ </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>INFO</level>
+ </filter>
+ </appender>
<root level="info">
<appender-ref ref="FILETRACE"/>
<appender-ref ref="FILEDEBUG"/>
@@ -280,9 +280,6 @@
<logger level="info" name="org.apache.iotdb.db.cost.statistic">
<appender-ref ref="FILE_COST_MEASURE"/>
</logger>
- <logger level="info" name="org.apache.iotdb.db.sync">
- <appender-ref ref="SYNC"/>
- </logger>
<logger level="info" name="IoTDB_AUDIT_LOGGER">
<appender-ref ref="AUDIT"/>
</logger>
@@ -299,4 +296,7 @@
<logger level="info" name="COMPACTION">
<appender-ref ref="COMPACTION"/>
</logger>
+ <logger level="info" name="org.apache.iotdb.db.pipe">
+ <appender-ref ref="PIPE"/>
+ </logger>
</configuration>
