Skip to content

Conversation

timsaucer
Copy link
Contributor

Related

Closes #10577

What

This PR updates the datafusion table provider to use 14 target streams, as per the default in DataFusion. It hashes the partition ID modulo 14 when creating the streams. In the next version we will pass through the target_partitions from the session context, but we have a larger effort to move to multiple streams ongoing. We will include passing through the target partition size as part of that larger effort.

…er the default. We will move to using the session context target partition size in a future PR
@timsaucer timsaucer self-assigned this Jul 10, 2025
@timsaucer timsaucer added do-not-merge Do not merge this PR exclude from changelog PRs with this won't show up in CHANGELOG.md dataplatform Rerun Data Platform integration labels Jul 10, 2025
@timsaucer timsaucer closed this Aug 12, 2025
@timsaucer timsaucer deleted the tsaucer/collecting_stream_14_partitions branch August 12, 2025 13:36
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
dataplatform Rerun Data Platform integration do-not-merge Do not merge this PR exclude from changelog PRs with this won't show up in CHANGELOG.md
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Queries failing with partition count mismatch
1 participant