diff --git a/go/vt/discovery/keyspace_events.go b/go/vt/discovery/keyspace_events.go index 2869ebf9e01..9f3381958a9 100644 --- a/go/vt/discovery/keyspace_events.go +++ b/go/vt/discovery/keyspace_events.go @@ -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) diff --git a/go/vt/vtgate/buffer/shard_buffer.go b/go/vt/vtgate/buffer/shard_buffer.go index b1f8c4538ec..c8ad1c9343f 100644 --- a/go/vt/vtgate/buffer/shard_buffer.go +++ b/go/vt/vtgate/buffer/shard_buffer.go @@ -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 {