From c12ee2f5cb5f2d8c905b4405d7ec8789b25926e2 Mon Sep 17 00:00:00 2001 From: Jiquan Long Date: Wed, 25 May 2022 17:03:59 +0800 Subject: [PATCH] Fix flow_graph_insert_buffer_node.go code style (#17216) Signed-off-by: longjiquan --- internal/datanode/flow_graph_insert_buffer_node.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/internal/datanode/flow_graph_insert_buffer_node.go b/internal/datanode/flow_graph_insert_buffer_node.go index 801dc740c8..d7b039a8fe 100644 --- a/internal/datanode/flow_graph_insert_buffer_node.go +++ b/internal/datanode/flow_graph_insert_buffer_node.go @@ -351,9 +351,7 @@ func (ibNode *insertBufferNode) Operate(in []Msg) []Msg { case resendTTMsg := <-ibNode.resendTTChan: log.Info("resend TT msg received in insertBufferNode", zap.Int64s("segment IDs", resendTTMsg.segmentIDs)) - if err := ibNode.writeHardTimeTick(fgMsg.timeRange.timestampMax, resendTTMsg.segmentIDs); err != nil { - log.Error("send hard time tick into pulsar channel failed", zap.Error(err)) - } + ibNode.writeHardTimeTick(fgMsg.timeRange.timestampMax, resendTTMsg.segmentIDs) default: } }