From 8e5ef8947a7e2595554322df057f98c6c051805b Mon Sep 17 00:00:00 2001 From: Nathan <148575555+nathan-artie@users.noreply.github.com> Date: Wed, 7 Feb 2024 20:48:27 -0800 Subject: [PATCH] Change log level to error for merge failures (#324) --- processes/consumer/flush.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/processes/consumer/flush.go b/processes/consumer/flush.go index 6972a08e8..1e483371c 100644 --- a/processes/consumer/flush.go +++ b/processes/consumer/flush.go @@ -90,7 +90,7 @@ func Flush(ctx context.Context, inMemDB *models.DatabaseData, dest destination.B if err != nil { tags["what"] = "merge_fail" - slog.With(logFields...).Warn(fmt.Sprintf("Failed to execute %s...not going to flush memory", action), slog.Any("err", err)) + slog.With(logFields...).Error(fmt.Sprintf("Failed to execute %s...not going to flush memory", action), slog.Any("err", err)) } else { slog.Info(fmt.Sprintf("%s success, clearing memory...", stringutil.CapitalizeFirstLetter(action)), logFields...) commitErr := commitOffset(ctx, _tableData.TopicConfig.Topic, _tableData.PartitionsToLastMessage)