Fix flowgraph when there are multiple upstreams (#14345)

Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-12-29 14:57:24 +08:00 · 2021-12-29 14:57:24 +08:00 · ecf3b6c262
parent 00b3fcb98b
commit ecf3b6c262
1 changed files with 1 additions and 1 deletions
--- a/internal/util/flowgraph/node.go
+++ b/internal/util/flowgraph/node.go
@ -169,7 +169,7 @@ func (nodeCtx *nodeCtx) collectInputMessages() {
 		t := nodeCtx.inputMessages[0].TimeTick()
 		latestTime := t
 		for i := 1; i < len(nodeCtx.inputMessages); i++ {
-			if t < nodeCtx.inputMessages[i].TimeTick() {
+			if latestTime < nodeCtx.inputMessages[i].TimeTick() {
 				latestTime = nodeCtx.inputMessages[i].TimeTick()
 			}
 		}