Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Clean up spawned task on SortStream drop #1105

Merged
merged 1 commit into from
Oct 12, 2021

Conversation

crepererum
Copy link
Contributor

This is only the first part for #1103.

I just want to check that the approach is OK. I think the testing infrastructure designed here (BlockingExec and BlockingStream) can later easily be reused. I you agree I would move it to datafusion::test::exec and add a bit more documentation.

The pin-project-lite update is required for PinnedDrop.

@github-actions github-actions bot added the datafusion Changes in the datafusion crate label Oct 11, 2021
Copy link
Contributor

@alamb alamb left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think this is a great change. The code looks good and the pattern for code and testing makes sense to me

Thanks @crepererum !

datafusion/src/physical_plan/sort.rs Outdated Show resolved Hide resolved
@alamb
Copy link
Contributor

alamb commented Oct 11, 2021

cc @Dandandan @houqp

Copy link
Contributor

@Dandandan Dandandan left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@crepererum crepererum force-pushed the crepererum/issue1103a branch from 1de1108 to 7be24fb Compare October 12, 2021 07:41
Copy link
Member

@houqp houqp left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thank you @crepererum , nice solution to the problem.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working datafusion Changes in the datafusion crate
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants