From 3dac2611b69a802f4942bdaba6675f1117079361 Mon Sep 17 00:00:00 2001 From: Cai Yudong Date: Fri, 8 Oct 2021 14:49:08 +0800 Subject: [PATCH] Remove redundant variable load (#9452) Signed-off-by: yudong.cai --- internal/datanode/flow_graph_insert_buffer_node.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/internal/datanode/flow_graph_insert_buffer_node.go b/internal/datanode/flow_graph_insert_buffer_node.go index 3e65278b79..cfa33f4fdd 100644 --- a/internal/datanode/flow_graph_insert_buffer_node.go +++ b/internal/datanode/flow_graph_insert_buffer_node.go @@ -291,9 +291,6 @@ func (ibNode *insertBufferNode) Operate(in []Msg) []Msg { log.Debug(".. Buffer not empty, flushing ..") finishCh := make(chan segmentFlushUnit, 1) - // Since buffer is not empty, so there must be data for key currentSegID - bd, _ := ibNode.insertBuffer.Load(currentSegID) - ibNode.flushMap.Store(currentSegID, bd.(*BufferData).buffer) clearFn := func() { finishCh <- segmentFlushUnit{field2Path: nil}