From ff5b893abdd184b2e45ac14ac28b691c559b3b05 Mon Sep 17 00:00:00 2001 From: yangxuan Date: Sat, 11 May 2024 15:53:56 +0800 Subject: [PATCH] fix data race Signed-off-by: yangxuan --- internal/datanode/io/binlog_io.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/datanode/io/binlog_io.go b/internal/datanode/io/binlog_io.go index 00a1b1de21940..bd470d21e6b9f 100644 --- a/internal/datanode/io/binlog_io.go +++ b/internal/datanode/io/binlog_io.go @@ -91,11 +91,11 @@ func (b *BinlogIoImpl) Upload(ctx context.Context, kvs map[string][]byte) error innerK, innerV := k, v future := b.pool.Submit(func() (any, error) { var err error - log.Debug("BinlogIO upload", zap.String("paths", k)) + log.Debug("BinlogIO upload", zap.String("paths", innerK)) err = retry.Do(ctx, func() error { err = b.Write(ctx, innerK, innerV) if err != nil { - log.Warn("BinlogIO fail to upload", zap.String("paths", k), zap.Error(err)) + log.Warn("BinlogIO fail to upload", zap.String("paths", innerK), zap.Error(err)) } return err })