From 78755263e24912a0c4c38904f3389aee33f6c97c Mon Sep 17 00:00:00 2001
From: Cai Yudong <yudong.cai@zilliz.com>
Date: Fri, 8 Oct 2021 17:43:46 +0800
Subject: [PATCH] Update ddnode test (#9477)

Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
---
 internal/datanode/flow_graph_dd_node_test.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/datanode/flow_graph_dd_node_test.go b/internal/datanode/flow_graph_dd_node_test.go
index 3121fa8327..882495661e 100644
--- a/internal/datanode/flow_graph_dd_node_test.go
+++ b/internal/datanode/flow_graph_dd_node_test.go
@@ -120,13 +120,13 @@ func TestFlowGraph_DDNode_Operate(to *testing.T) {
 					collectionID: test.ddnCollID,
 				}
 
-				var createCollMsg msgstream.TsMsg = &msgstream.DropCollectionMsg{
+				var dropCollMsg msgstream.TsMsg = &msgstream.DropCollectionMsg{
 					DropCollectionRequest: internalpb.DropCollectionRequest{
 						Base:         &commonpb.MsgBase{MsgType: commonpb.MsgType_DropCollection},
 						CollectionID: test.msgCollID,
 					},
 				}
-				tsMessages := []msgstream.TsMsg{createCollMsg}
+				tsMessages := []msgstream.TsMsg{dropCollMsg}
 				var msgStreamMsg Msg = flowgraph.GenerateMsgStreamMsg(tsMessages, 0, 0, nil, nil)
 
 				rt := ddn.Operate([]Msg{msgStreamMsg})