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 09d9c44 commit 466dde3
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 5 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 @@ -281,10 +281,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
4 changes: 3 additions & 1 deletion go/vt/vtgate/buffer/shard_buffer.go
Original file line number Diff line number Diff line change
Expand Up @@ -480,7 +480,9 @@ 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)", sb.keyspace, sb.shard, stillServing)
// 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)", sb.keyspace, sb.shard, stillServing)

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

0 comments on commit 466dde3

Please sign in to comment.