From 3ab8b9af257e065a8119769208aae682367913d3 Mon Sep 17 00:00:00 2001
From: xige-16 <xi.ge@zilliz.com>
Date: Sat, 27 Mar 2021 11:16:20 +0800
Subject: [PATCH] Dlete unlocked mutex in seek function

Signed-off-by: xige-16 <xi.ge@zilliz.com>
---
 internal/msgstream/ms/msgstream_impl.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/internal/msgstream/ms/msgstream_impl.go b/internal/msgstream/ms/msgstream_impl.go
index d2fa63f72..d663df247 100644
--- 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
-- 
GitLab