This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch force_ci/object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 401c5e9208e88252fd8b68bf98be2e4d781ff06e Author: Caideyipi <[email protected]> AuthorDate: Thu Nov 13 14:23:43 2025 +0800 Pipe: Trimmed some of the pipe logs (#16747) * fix * fix (cherry picked from commit e53d27c0ad096a0788ac9da2664b35ddaf1bde02) --- .../src/assembly/resources/conf/logback-datanode.xml | 15 --------------- .../receiver/visitor/PipeStatementTSStatusVisitor.java | 5 +++-- 2 files changed, 3 insertions(+), 17 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 557fd8b160f..e827a7cbef2 100644 --- a/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml +++ b/iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml @@ -207,21 +207,6 @@ <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.TimeBasedRollingPolicy"> - <fileNamePattern>${IOTDB_HOME}/logs/log-datanode-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>INFO</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"> diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementTSStatusVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementTSStatusVisitor.java index 31eecc7b3a9..198e8edb677 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementTSStatusVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementTSStatusVisitor.java @@ -98,8 +98,9 @@ public class PipeStatementTSStatusVisitor extends StatementVisitor<TSStatus, TSS @Override public TSStatus visitInsertBase( final InsertBaseStatement insertBaseStatement, final TSStatus context) { - if (context.getCode() == TSStatusCode.SYSTEM_READ_ONLY.getStatusCode() - || context.getCode() == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode()) { + // If the system is read-only, we shall not classify it into temporary unavailable exception to + // avoid to many logs + if (context.getCode() == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode()) { return new TSStatus( TSStatusCode.PIPE_RECEIVER_TEMPORARY_UNAVAILABLE_EXCEPTION.getStatusCode()) .setMessage(context.getMessage());
