From e36c9516271f26ce65543bbc8fc9350cfb2fa57b Mon Sep 17 00:00:00 2001 From: nhsmw Date: Mon, 9 Mar 2026 16:53:04 +0800 Subject: [PATCH] Add condition to check for TryRemoving in dispatcher --- downstreamadapter/dispatchermanager/dispatcher_manager.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/downstreamadapter/dispatchermanager/dispatcher_manager.go b/downstreamadapter/dispatchermanager/dispatcher_manager.go index 5867785136..d22ef43db5 100644 --- a/downstreamadapter/dispatchermanager/dispatcher_manager.go +++ b/downstreamadapter/dispatchermanager/dispatcher_manager.go @@ -743,6 +743,9 @@ func (e *DispatcherManager) aggregateDispatcherHeartbeats(needCompleteStatus boo } if needCompleteStatus { + if dispatcherItem.GetTryRemoving() { + return + } if watermark != nil { eventServiceDispatcherHeartbeat.Append(event.NewDispatcherProgress(id, watermark.CheckpointTs)) } else {