File tree Expand file tree Collapse file tree 1 file changed +8
-0
lines changed
pkg/spanconfig/spanconfigreconciler Expand file tree Collapse file tree 1 file changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -7,6 +7,7 @@ package spanconfigreconciler
7
7
8
8
import (
9
9
"context"
10
+ "runtime/trace"
10
11
"time"
11
12
12
13
"github.com/cockroachdb/cockroach/pkg/keys"
@@ -139,6 +140,7 @@ func (r *Reconciler) Reconcile(
139
140
session sqlliveness.Session ,
140
141
onCheckpoint func () error ,
141
142
) error {
143
+ defer trace .StartRegion (ctx , "spanconfig.Reconciler.Reconcile" ).End ()
142
144
// TODO(irfansharif): Avoid the full reconciliation pass if the startTS
143
145
// provided is visible to the rangefeed. Right now we're doing a full
144
146
// reconciliation pass every time the reconciliation job kicks us off.
@@ -185,6 +187,9 @@ func (r *Reconciler) Reconcile(
185
187
r .mu .lastCheckpoint = reconciledUpUntil
186
188
r .mu .Unlock ()
187
189
190
+ if log .V (3 ) {
191
+ log .Dev .Infof (ctx , "reconciled up until %s" , reconciledUpUntil )
192
+ }
188
193
return onCheckpoint ()
189
194
})
190
195
}
@@ -502,6 +507,9 @@ func (r *incrementalReconciler) reconcile(
502
507
if len (sqlUpdates ) == 0 {
503
508
return callback (checkpoint ) // nothing to do; propagate the checkpoint
504
509
}
510
+ if log .V (3 ) {
511
+ log .Dev .Infof (ctx , "processing %d SQL updates" , len (sqlUpdates ))
512
+ }
505
513
506
514
// Process the SQLUpdates and identify all descriptor IDs that require
507
515
// translation. If the SQLUpdates includes ProtectedTimestampUpdates then
You can’t perform that action at this time.
0 commit comments