Skip to content

Commit e53d27c

Browse files
authored
Pipe: Trimmed some of the pipe logs (apache#16747)
* fix * fix
1 parent f608a2d commit e53d27c

File tree

2 files changed

+3
-17
lines changed

2 files changed

+3
-17
lines changed

iotdb-core/datanode/src/assembly/resources/conf/logback-datanode.xml

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -207,21 +207,6 @@
207207
<level>INFO</level>
208208
</filter>
209209
</appender>
210-
<appender class="ch.qos.logback.core.rolling.RollingFileAppender" name="PIPE">
211-
<file>${IOTDB_HOME}/logs/log_datanode_pipe.log</file>
212-
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
213-
<fileNamePattern>${IOTDB_HOME}/logs/log-datanode-pipe-%d{yyyyMMdd}.log.gz</fileNamePattern>
214-
<maxHistory>30</maxHistory>
215-
</rollingPolicy>
216-
<append>true</append>
217-
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
218-
<pattern>%d [%t] %-5p %C{25}:%L - %m %n</pattern>
219-
<charset>utf-8</charset>
220-
</encoder>
221-
<filter class="ch.qos.logback.classic.filter.ThresholdFilter">
222-
<level>INFO</level>
223-
</filter>
224-
</appender>
225210
<appender class="ch.qos.logback.core.rolling.RollingFileAppender" name="EXPLAIN_ANALYZE">
226211
<file>${IOTDB_HOME}/logs/log_explain_analyze.log</file>
227212
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementTSStatusVisitor.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,8 +98,9 @@ public TSStatus visitInsertMultiTablets(
9898
@Override
9999
public TSStatus visitInsertBase(
100100
final InsertBaseStatement insertBaseStatement, final TSStatus context) {
101-
if (context.getCode() == TSStatusCode.SYSTEM_READ_ONLY.getStatusCode()
102-
|| context.getCode() == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode()) {
101+
// If the system is read-only, we shall not classify it into temporary unavailable exception to
102+
// avoid to many logs
103+
if (context.getCode() == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode()) {
103104
return new TSStatus(
104105
TSStatusCode.PIPE_RECEIVER_TEMPORARY_UNAVAILABLE_EXCEPTION.getStatusCode())
105106
.setMessage(context.getMessage());

0 commit comments

Comments
 (0)