Dlete unlocked mutex in seek function

Signed-off-by: N xige-16 <xi.ge@zilliz.com>

Dlete unlocked mutex in seek function
Signed-off-by: N xige-16 <xi.ge@zilliz.com>
3ab8b9af · xige-16 · yefu.chen · a48d46cf · 3ab8b9af
隐藏空白更改
内联并排

Showing with 0 addition and 1 deletion

internal/msgstream/ms/msgstream_impl.go internal/msgstream/ms/msgstream_impl.go +0 -1

未找到文件。
--- a/internal/msgstream/ms/msgstream_impl.go
+++ b/internal/msgstream/ms/msgstream_impl.go
@@ -730,7 +730,6 @@ func (ms *TtMsgStream) Seek(mp *internalpb.MsgPosition) error {
 			}
 			if tsMsg.Type() == commonpb.MsgType_TimeTick {
 				if tsMsg.BeginTs() >= mp.Timestamp {
-					ms.unsolvedMutex.Unlock()
 					return nil
 				}
 				continue