fix DynamicStream blocking

pingcap · Aug 12, 2024 · 6699cdf · 6699cdf
1 parent 3f8a2dd
commit 6699cdf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/utils/dynstream/stream.go b/utils/dynstream/stream.go
@@ -288,7 +288,7 @@ Loop:
 				}
 
 				now := time.Now()
-				s.handler.Handle(e, signal.pathInfo.dest)
+				signal.pathInfo.blocking = s.handler.Handle(e, signal.pathInfo.dest)
 
 				s.donChan <- doneInfo[P, T, D]{pathInfo: signal.pathInfo, handleTime: time.Since(now)}