Skip to content

Commit

Permalink
fix: fix panic when creating sink into table under pause (#17896)
Browse files Browse the repository at this point in the history
  • Loading branch information
yezizp2012 authored Aug 2, 2024
1 parent 03e4bc3 commit c395db7
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions src/stream/src/executor/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -457,6 +457,7 @@ impl Barrier {
Some(
Mutation::Update { .. } // new actors for scaling
| Mutation::Add(AddMutation { pause: true, .. }) // new streaming job, or recovery
| Mutation::AddAndUpdate(AddMutation { pause: true, .. }, _) // new actors for replacing table
) => true,
_ => false,
}
Expand Down

0 comments on commit c395db7

Please sign in to comment.