feat: expose parallelism_policy in fragment metadata and system catalog #23524
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Introduce a new
parallelism_policyfield to fragment distribution metadata and propagate it through controller, meta service, and system catalog for improved visibility.parallelism_policytoFragmentDistributionin protoparallelism_policyinrw_fragmentssystem catalogI hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.
What's changed and what's your intention?
Summary
This PR enriches the fragment metadata by introducing a new field,
parallelism_policy, to the streaming fragment system. Theparallelism_policyfield exposes the underlying logic and reasoning for each fragment’s parallelism configuration, improving transparency and debuggability across the backend, API, and frontend system catalog.Details
parallelism_policystring field to theFragmentDistributionprotobuf schema and propagates it to all relevant Rust structs (FragmentDesc,FragmentDistribution,RwFragment), ensuring consistent metadata exposure throughout the stack.parallelism_policyfield via the frontend system catalog table (rw_fragments), enabling users and tools to query and understand the parallelism configuration and its rationale for every fragment.Checklist
Documentation
Release note