Skip to content

fix(sort): record output_batches, output_bytes and end_time for when not using merge sort#22878

Draft
rluvaton wants to merge 9 commits into
apache:mainfrom
rluvaton:fix-sort-metrics
Draft

fix(sort): record output_batches, output_bytes and end_time for when not using merge sort#22878
rluvaton wants to merge 9 commits into
apache:mainfrom
rluvaton:fix-sort-metrics

Conversation

@rluvaton

Copy link
Copy Markdown
Member

Which issue does this PR close?

N/A

Rationale for this change

When only using in mem sort without going through the StreamingMergeBuilder some metrics are not being recorded

What changes are included in this PR?

wrap in ObservedStream for streams that returned to the next operator

Are these changes tested?

Not yet

Are there any user-facing changes?

no

@github-actions github-actions Bot added the physical-plan Changes to the physical-plan crate label Jun 10, 2026
@github-actions github-actions Bot added the core Core DataFusion crate label Jun 10, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

core Core DataFusion crate physical-plan Changes to the physical-plan crate

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant