Skip to content

Commit 0e5c8ad

Browse files
craig[bot]stevendanna
andcommitted
Merge #153414
153414: kvcoord: log batch when flushing r=miraradeva a=stevendanna We intended to log the batch here so that we can more easily debug any issue related to batch options. Epic: none Release note: None Co-authored-by: Steven Danna <[email protected]>
2 parents 2a6fdac + 1d8d3ef commit 0e5c8ad

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

pkg/kv/kvclient/kvcoord/txn_interceptor_write_buffer.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1816,8 +1816,8 @@ func (twb *txnWriteBuffer) flushBufferAndSendBatch(
18161816
flushBatch := ba.ShallowCopy()
18171817
clearBatchRequestOptions(flushBatch)
18181818
flushBatch.Requests = reqs
1819-
log.VEventf(ctx, 2, "flushing %d buffered requests via separate batch", len(reqs))
18201819

1820+
log.VEventf(ctx, 2, "flushing %d buffered requests in separate batch: %v", len(reqs), ba)
18211821
br, pErr := twb.wrapped.SendLocked(ctx, flushBatch)
18221822
if pErr != nil {
18231823
pErr.Index = nil
@@ -1832,6 +1832,8 @@ func (twb *txnWriteBuffer) flushBufferAndSendBatch(
18321832
} else {
18331833
ba = ba.ShallowCopy()
18341834
ba.Requests = append(reqs, ba.Requests...)
1835+
1836+
log.VEventf(ctx, 2, "flushing %d buffered requests in batch: %v", len(reqs), ba)
18351837
br, pErr := twb.wrapped.SendLocked(ctx, ba)
18361838
if pErr != nil {
18371839
return nil, twb.adjustErrorUponFlush(ctx, numRevisionsBuffered, pErr)

0 commit comments

Comments
 (0)