(iotdb) branch pipe-flush updated: gsa

[justinchen]

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

justinchen pushed a commit to branch pipe-flush
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/pipe-flush by this push:
     new 7cbf7d93540 gsa
7cbf7d93540 is described below

commit 7cbf7d93540cdacc3881ce223f89eea4ed9f1f9d
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Feb 13 16:28:26 2026 +0800

    gsa
---
 .../dataregion/realtime/PipeRealtimeDataRegionTsFileSource.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionTsFileSource.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionTsFileSource.java
index 7c9d5149817..be1f648d163 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionTsFileSource.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionTsFileSource.java
@@ -39,7 +39,7 @@ public class PipeRealtimeDataRegionTsFileSource extends 
PipeRealtimeDataRegionSo
       LoggerFactory.getLogger(PipeRealtimeDataRegionTsFileSource.class);
 
   @Override
-  protected void doExtract(PipeRealtimeEvent event) {
+  protected void doExtract(final PipeRealtimeEvent event) {
     
PipeTsFileEpochProgressIndexAndFlushManager.getInstance().flushAllTimeoutTsFiles();
 
     if (event.getEvent() instanceof PipeHeartbeatEvent) {
@@ -66,7 +66,7 @@ public class PipeRealtimeDataRegionTsFileSource extends 
PipeRealtimeDataRegionSo
       // Pending is unbounded, so it should never reach capacity.
       final String errorMessage =
           String.format(
-              "extract: pending queue of PipeRealtimeDataRegionTsFileExtractor 
%s "
+              "extract: pending queue of PipeRealtimeDataRegionTsFileSource %s 
"
                   + "has reached capacity, discard TsFile event %s, current 
state %s",
               this, event, event.getTsFileEpoch().getState(this));
       LOGGER.error(errorMessage);