From 4f66bcbb22b841ce1f00dd76852c1216aa666d91 Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Wed, 8 Jun 2022 17:24:07 +0800 Subject: [PATCH] Fix DataNode processes event out of order (#17440) The probability is low so very unlikly to reproduce See also: #15966 Signed-off-by: yangxuan --- internal/datanode/data_node.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/datanode/data_node.go b/internal/datanode/data_node.go index fdc4f188e0..d1a9b59b66 100644 --- a/internal/datanode/data_node.go +++ b/internal/datanode/data_node.go @@ -259,7 +259,8 @@ func (node *DataNode) StartWatchChannels(ctx context.Context) { return } for _, evt := range event.Events { - go node.handleChannelEvt(evt) + // We need to stay in order until events enqueued + node.handleChannelEvt(evt) } } }