chore: close stream section reader (#20107)

5 months ago · 356cd36d8e
parent 728b308edf
commit 356cd36d8e
1 changed files with 1 additions and 0 deletions
--- a/pkg/engine/internal/executor/streams_view.go
+++ b/pkg/engine/internal/executor/streams_view.go
@ -171,6 +171,7 @@ func (v *streamsView) init(ctx context.Context) (err error) {
 	}

 	r := streams.NewReader(readerOptions)
+	defer r.Close()

 	var records []arrow.RecordBatch