From ecf3b6c2625923448e517f794ec9c4853d73c624 Mon Sep 17 00:00:00 2001 From: Jiquan Long Date: Wed, 29 Dec 2021 14:57:24 +0800 Subject: [PATCH] Fix flowgraph when there are multiple upstreams (#14345) Signed-off-by: dragondriver --- internal/util/flowgraph/node.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/util/flowgraph/node.go b/internal/util/flowgraph/node.go index 5c5c367b4..92fc8b29a 100644 --- 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() } } -- GitLab