(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Trimmed some of the pipe logs (#16747) (#16754)

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 72a3f45884e [To dev/1.3] Pipe: Trimmed some of the pipe logs (#16747) 
(#16754)
72a3f45884e is described below

commit 72a3f45884ebcdda52debcc36eda173f0bfa6ea8
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Nov 14 16:25:03 2025 +0800

    [To dev/1.3] Pipe: Trimmed some of the pipe logs (#16747) (#16754)
---
 .../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 94c3c418f21..afb70d3c0c2 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
@@ -97,8 +97,9 @@ public class PipeStatementTSStatusVisitor extends 
StatementVisitor<TSStatus, TSS
 
   private 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());