diff --git a/src/meta/src/model/stream.rs b/src/meta/src/model/stream.rs index cd2c71bf2e12..139581d46f43 100644 --- a/src/meta/src/model/stream.rs +++ b/src/meta/src/model/stream.rs @@ -55,7 +55,7 @@ impl From for TableParallelism { Some(Fixed(FixedParallelism { parallelism: n })) => Self::Fixed(*n as usize), Some(Auto(_)) => Self::Auto, Some(Custom(_)) => Self::Custom, - _ => Self::Auto, + _ => unreachable!(), } } }