diff --git a/pkg/storage/pebble.go b/pkg/storage/pebble.go index 8170081bc4a6..9b03e8c750c1 100644 --- a/pkg/storage/pebble.go +++ b/pkg/storage/pebble.go @@ -1192,6 +1192,11 @@ func (p *Pebble) async(fn func()) { func (p *Pebble) makeMetricEtcEventListener(ctx context.Context) pebble.EventListener { return pebble.EventListener{ + BackgroundError: func(err error) { + if errors.Is(err, pebble.ErrCorruption) { + log.Fatalf(ctx, "local corruption detected: %v", err) + } + }, WriteStallBegin: func(info pebble.WriteStallBeginInfo) { atomic.AddInt64(&p.writeStallCount, 1) startNanos := timeutil.Now().UnixNano()