diff --git a/pkg/sql/distsqlrun/backfiller.go b/pkg/sql/distsqlrun/backfiller.go index 4310edb99ef2..d1b1966a9e76 100644 --- a/pkg/sql/distsqlrun/backfiller.go +++ b/pkg/sql/distsqlrun/backfiller.go @@ -129,6 +129,7 @@ func (b *backfiller) mainLoop(ctx context.Context) error { if err := b.chunks.prepare(ctx); err != nil { return err } + defer b.chunks.close(ctx) var resume roachpb.Span sp := work