未验证 提交 2a98ce27 编写于 作者: B bigsheeper 提交者: GitHub

[skip ci] Add comment for filterInvalidDeleteMessage (#12733)

Signed-off-by: Nbigsheeper <yihao.dai@zilliz.com>
上级 a34b1a3e
...@@ -104,6 +104,7 @@ func (fdmNode *filterDmNode) Operate(in []flowgraph.Msg) []flowgraph.Msg { ...@@ -104,6 +104,7 @@ func (fdmNode *filterDmNode) Operate(in []flowgraph.Msg) []flowgraph.Msg {
return []Msg{res} return []Msg{res}
} }
// filterInvalidDeleteMessage would filter out invalid delete messages
func (fdmNode *filterDmNode) filterInvalidDeleteMessage(msg *msgstream.DeleteMsg) *msgstream.DeleteMsg { func (fdmNode *filterDmNode) filterInvalidDeleteMessage(msg *msgstream.DeleteMsg) *msgstream.DeleteMsg {
sp, ctx := trace.StartSpanFromContext(msg.TraceCtx()) sp, ctx := trace.StartSpanFromContext(msg.TraceCtx())
msg.SetTraceCtx(ctx) msg.SetTraceCtx(ctx)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册