From 2de5cf7762ff0145a5d0e5d6cf0990feddc6a54c Mon Sep 17 00:00:00 2001 From: congqixia Date: Mon, 20 Dec 2021 12:22:43 +0800 Subject: [PATCH] [skip e2e] Improve log in flush manager (#13689) Signed-off-by: Congqi Xia --- internal/datanode/flush_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datanode/flush_manager.go b/internal/datanode/flush_manager.go index 8747ca6396..6176f6dd5d 100644 --- a/internal/datanode/flush_manager.go +++ b/internal/datanode/flush_manager.go @@ -674,7 +674,7 @@ func dropVirtualChannelFunc(dsService *dataSyncService, opts ...retry.Option) fl func flushNotifyFunc(dsService *dataSyncService, opts ...retry.Option) notifyMetaFunc { return func(pack *segmentFlushPack) { if pack.err != nil { - log.Warn("flush pack with error, data node quit now") + log.Error("flush pack with error, DataNode quit now", zap.Error(pack.err)) // TODO silverxia change to graceful stop datanode panic(pack.err) }