diff --git a/internal/datanode/binlog_io.go b/internal/datanode/binlog_io.go index da8aba33bc..d41f0f82ea 100644 --- a/internal/datanode/binlog_io.go +++ b/internal/datanode/binlog_io.go @@ -201,7 +201,10 @@ func (b *binlogIO) upload( for err != nil { select { case <-ctx.Done(): - log.Warn("ctx done when saving kvs to blob storage", zap.Any("key values", kvs)) + log.Warn("ctx done when saving kvs to blob storage", + zap.Int64("collectionID", meta.GetID()), + zap.Int64("segmentID", segID), + zap.Int("number of kvs", len(kvs))) return nil, errUploadToBlobStorage default: if err != errStart {