From e8038a76e164a07f6f1d068bb9c679e018df4ecb Mon Sep 17 00:00:00 2001 From: congqixia Date: Thu, 25 Jul 2024 22:17:45 +0800 Subject: [PATCH] fix: Remove timeout in datanode watch ctx (#35011) See also #35008 Use tickle timeout logic instead of hardcode context timeout Signed-off-by: Congqi Xia --- internal/datanode/channel/channel_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datanode/channel/channel_manager.go b/internal/datanode/channel/channel_manager.go index 412a0eccf5..9a8a4464a4 100644 --- a/internal/datanode/channel/channel_manager.go +++ b/internal/datanode/channel/channel_manager.go @@ -345,7 +345,7 @@ func (r *opRunner) watchWithTimer(info *datapb.ChannelWatchInfo) *opState { ) watchTimeout := paramtable.Get().DataCoordCfg.WatchTimeoutInterval.GetAsDuration(time.Second) - ctx, cancel := context.WithTimeout(context.Background(), watchTimeout) + ctx, cancel := context.WithCancel(context.Background()) defer cancel() startTimer := func(finishWg *sync.WaitGroup) {