diff --git a/internal/datacoord/channel_manager_test.go b/internal/datacoord/channel_manager_test.go index 0f3c5588f6a25135de205616e849b851a4108c68..5892af1ef21faabe8f3c16027d2cbfb3019ffba1 100644 --- a/internal/datacoord/channel_manager_test.go +++ b/internal/datacoord/channel_manager_test.go @@ -190,7 +190,6 @@ func TestChannelManager_StateTransfer(t *testing.T) { nodeID: nodeID, } chManager.stateTimer.notifyTimeoutWatcher(e) - chManager.stateTimer.stopIfExist(e) waitAndCheckState(t, metakv, datapb.ChannelWatchState_ToRelease, nodeID, cName, collectionID) assert.Eventually(t, func() bool {