From f2e551e9a07183eba18bee64fc6f8f486ee332e9 Mon Sep 17 00:00:00 2001
From: xige-16 <xi.ge@zilliz.com>
Date: Thu, 10 Jun 2021 14:32:51 +0800
Subject: [PATCH] Add asConsumer before seek (#5706)

* add asConsumer before seek

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

* get dmChannel from master

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

* use pChannel instead in queryservice

Signed-off-by: xige-16 <xi.ge@zilliz.com>
---
 internal/querynode/flow_graph_query_node.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/querynode/flow_graph_query_node.go b/internal/querynode/flow_graph_query_node.go
index 4de13bc21c..e8d47968c5 100644
--- a/internal/querynode/flow_graph_query_node.go
+++ b/internal/querynode/flow_graph_query_node.go
@@ -127,6 +127,7 @@ func (q *queryNodeFlowGraph) consumerFlowGraph(channel VChannel, subName Consume
 }
 
 func (q *queryNodeFlowGraph) seekQueryNodeFlowGraph(position *internalpb.MsgPosition) error {
+	q.dmlStream.AsConsumer([]string{position.ChannelName}, position.MsgGroup)
 	err := q.dmlStream.Seek([]*internalpb.MsgPosition{position})
 	return err
 }