This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch 1.3-mutli in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ba245c6b16e3df0234068e8a587bf3f70d5ce133 Author: Caideyipi <[email protected]> AuthorDate: Mon Apr 27 15:03:58 2026 +0800 [To dev/1.3] Pipe: Fixed the failed logic for compressing progressReportEvent (#17457) --- .../source/dataregion/realtime/PipeRealtimeDataRegionSource.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionSource.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionSource.java index 3c03ee732d0..367c8327421 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionSource.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionSource.java @@ -382,8 +382,11 @@ public abstract class PipeRealtimeDataRegionSource implements PipeExtractor { } pendingQueue.pollLast(); } - if (pendingQueue.peekLast() instanceof ProgressReportEvent) { - final ProgressReportEvent oldEvent = (ProgressReportEvent) pendingQueue.peekLast(); + final Event last = pendingQueue.peekLast(); + if (last instanceof PipeRealtimeEvent + && ((PipeRealtimeEvent) last).getEvent() instanceof ProgressReportEvent) { + final ProgressReportEvent oldEvent = + (ProgressReportEvent) ((PipeRealtimeEvent) last).getEvent(); oldEvent.bindProgressIndex( oldEvent .getProgressIndex()
