Skip to content

Commit

Permalink
fix: Mixing arrangement backfill and no shuffle backfill can lead to …
Browse files Browse the repository at this point in the history
…scale failure part 2 (#16983)
  • Loading branch information
shanicky authored May 29, 2024
1 parent 234f657 commit a3339ba
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions src/meta/src/stream/scale.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2525,9 +2525,7 @@ impl ScaleController {
// We trace the upstreams of each downstream under the hierarchy until we reach the top
// for every no_shuffle relation.
while let Some(fragment_id) = queue.pop_front() {
if !no_shuffle_target_fragment_ids.contains(&fragment_id)
&& !no_shuffle_source_fragment_ids.contains(&fragment_id)
{
if !no_shuffle_target_fragment_ids.contains(&fragment_id) {
continue;
}

Expand Down

0 comments on commit a3339ba

Please sign in to comment.