Skip to content

Commit ba245c6

Browse files
committed
[To dev/1.3] Pipe: Fixed the failed logic for compressing progressReportEvent (#17457)
1 parent e96ce95 commit ba245c6

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionSource.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -382,8 +382,11 @@ protected void extractProgressReportEvent(final PipeRealtimeEvent event) {
382382
}
383383
pendingQueue.pollLast();
384384
}
385-
if (pendingQueue.peekLast() instanceof ProgressReportEvent) {
386-
final ProgressReportEvent oldEvent = (ProgressReportEvent) pendingQueue.peekLast();
385+
final Event last = pendingQueue.peekLast();
386+
if (last instanceof PipeRealtimeEvent
387+
&& ((PipeRealtimeEvent) last).getEvent() instanceof ProgressReportEvent) {
388+
final ProgressReportEvent oldEvent =
389+
(ProgressReportEvent) ((PipeRealtimeEvent) last).getEvent();
387390
oldEvent.bindProgressIndex(
388391
oldEvent
389392
.getProgressIndex()

0 commit comments

Comments
 (0)