mirror of https://github.com/milvus-io/milvus.git
fix use pChannel in seek position (#25611)
Signed-off-by: Wei Liu <wei.liu@zilliz.com>pull/25595/head
parent
74ad7c4601
commit
51c348158b
|
@ -225,6 +225,8 @@ func (d *Dispatcher) work() {
|
|||
}
|
||||
if err != nil {
|
||||
t.pos = pack.StartPositions[0]
|
||||
// replace the pChannel with vChannel
|
||||
t.pos.ChannelName = t.vchannel
|
||||
d.lagTargets.LoadOrStore(t.vchannel, t)
|
||||
d.nonBlockingNotify()
|
||||
delete(d.targets, vchannel)
|
||||
|
|
Loading…
Reference in New Issue