Skip to content

Commit

Permalink
Patch: disable extensive keyspace events logging
Browse files Browse the repository at this point in the history
  • Loading branch information
tanjinx committed Nov 7, 2024
1 parent 4e3f068 commit 2e3f7ef
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 6 deletions.
10 changes: 6 additions & 4 deletions go/vt/discovery/keyspace_events.go
Original file line number Diff line number Diff line change
Expand Up @@ -312,10 +312,12 @@ func (kss *keyspaceState) ensureConsistentLocked() {
Serving: sstate.serving,
})

log.Infof("keyspace event resolved: %s/%s is now consistent (serving: %v)",
sstate.target.Keyspace, sstate.target.Keyspace,
sstate.serving,
)
// Disable it due to log storm in production
// thread https://slack-pde.slack.com/archives/C06CPL4HMED/p1729896804879749
// log.Infof("keyspace event resolved: %s/%s is now consistent (serving: %v)",
// sstate.target.Keyspace, sstate.target.Keyspace,
// sstate.serving,
// )

if !sstate.serving {
delete(kss.shards, shard)
Expand Down
6 changes: 4 additions & 2 deletions go/vt/vtgate/buffer/shard_buffer.go
Original file line number Diff line number Diff line change
Expand Up @@ -475,8 +475,10 @@ func (sb *shardBuffer) recordKeyspaceEvent(alias *topodatapb.TabletAlias, stillS
sb.mu.Lock()
defer sb.mu.Unlock()

log.Infof("disruption in shard %s/%s resolved (serving: %v), movetable state %#v",
sb.keyspace, sb.shard, stillServing, keyspaceEvent.MoveTablesState)
// Disable it due to log storm in production
// thread https://slack-pde.slack.com/archives/C06CPL4HMED/p1729896804879749
// log.Infof("disruption in shard %s/%s resolved (serving: %v), movetable state %#v",
// sb.keyspace, sb.shard, stillServing, keyspaceEvent.MoveTablesState)

if !topoproto.TabletAliasEqual(alias, sb.currentPrimary) {
if sb.currentPrimary != nil {
Expand Down

0 comments on commit 2e3f7ef

Please sign in to comment.