From 28d305148ab71913aae237222e8b35176dbbbf46 Mon Sep 17 00:00:00 2001 From: Cai Yudong Date: Sun, 26 Sep 2021 09:43:57 +0800 Subject: [PATCH] Update ddnode insert (#8536) Signed-off-by: yudong.cai --- internal/datanode/flow_graph_dd_node.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datanode/flow_graph_dd_node.go b/internal/datanode/flow_graph_dd_node.go index 52df9ead7a..ae28faa69e 100644 --- a/internal/datanode/flow_graph_dd_node.go +++ b/internal/datanode/flow_graph_dd_node.go @@ -96,7 +96,7 @@ func (ddn *ddNode) Operate(in []Msg) []Msg { continue } } - iMsg.insertMessages = append(iMsg.insertMessages, msg.(*msgstream.InsertMsg)) + iMsg.insertMessages = append(iMsg.insertMessages, imsg) } }