fix data race

Signed-off-by: yangxuan <[email protected]>
XuanYang-cn · May 11, 2024 · ff5b893 · ff5b893
1 parent 1c59781
commit ff5b893
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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
 			})