Update ddnode insert (#8536)

Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
2021-09-26 09:43:57 +08:00 · 2021-09-26 09:43:57 +08:00 · 28d305148a
parent 68f73302a5
commit 28d305148a
1 changed files with 1 additions and 1 deletions
--- 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)
 		}
 	}