Merge #111803

111803: streamproducer: add verbose logging to span config event stream r=stevendanna a=msbutler It was helpful while looking into #111541 Epic: none Release Note: none Co-authored-by: Michael Butler <[email protected]>
cockroachdb · Oct 5, 2023 · 767e135 · 767e135
2 parents 45fe752 + c577c50
commit 767e135
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/ccl/streamingccl/streamproducer/span_config_event_stream.go b/pkg/ccl/streamingccl/streamproducer/span_config_event_stream.go
@@ -268,7 +268,9 @@ func (s *spanConfigEventStream) streamLoop(ctx context.Context) error {
 			batcher.addSpanConfigs(bufferedEvents, update.Timestamp)
 			bufferedEvents = bufferedEvents[:0]
 			if pacer.shouldCheckpoint(update.Timestamp, true) || fromFullScan {
+				log.VEventf(ctx, 2, "checkpointing span config stream at %s", update.Timestamp.GoTime())
 				if batcher.getSize() > 0 {
+					log.VEventf(ctx, 2, "sending %d span config events", len(batcher.batch.SpanConfigs))
 					if err := s.flushEvent(ctx, &streampb.StreamEvent{Batch: &batcher.batch}); err != nil {
 						return err
 					}