Fix DataNode processes event out of order (milvus-io#17440)

The probability is low so very unlikly to reproduce See also: milvus-io#15966 Signed-off-by: yangxuan <xuan.yang@zilliz.com>
zhagnlu · Jun 8, 2022 · 4f66bcb · 4f66bcb
1 parent a085421
commit 4f66bcb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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)
 			}
 		}
 	}