From 6069a7d42b0ef354c277e64ef1a4448fe1ad6d50 Mon Sep 17 00:00:00 2001 From: smellthemoon <64083300+smellthemoon@users.noreply.github.com> Date: Wed, 30 Aug 2023 17:13:00 +0800 Subject: [PATCH] Log out memory in MB (#26262) Signed-off-by: lixinguo Co-authored-by: lixinguo --- internal/datanode/flow_graph_manager.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/internal/datanode/flow_graph_manager.go b/internal/datanode/flow_graph_manager.go index 95b01b2ebe..66b08c6244 100644 --- a/internal/datanode/flow_graph_manager.go +++ b/internal/datanode/flow_graph_manager.go @@ -91,11 +91,15 @@ func (fm *flowgraphManager) execute(totalMemory uint64) { return } + toMB := func(mem float64) float64 { + return mem / 1024 / 1024 + } + memoryWatermark := float64(totalMemory) * Params.DataNodeCfg.MemoryWatermark.GetAsFloat() if float64(total) < memoryWatermark { log.RatedDebug(5, "skip force sync because memory level is not high enough", - zap.Float64("current_total_memory_usage", float64(total)), - zap.Float64("current_memory_watermark", memoryWatermark), + zap.Float64("current_total_memory_usage", toMB(float64(total))), + zap.Float64("current_memory_watermark", toMB(memoryWatermark)), zap.Any("channel_memory_usages", channels)) return }