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) {