fix(scale): Remove the wrong assert for broadcast dispatcher in the s…

…caling post apply stage (#18681)
risingwavelabs · Sep 25, 2024 · dac92a4 · dac92a4
1 parent 97f3d9c
commit dac92a4
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/meta/src/controller/streaming_job.rs b/src/meta/src/controller/streaming_job.rs
@@ -1631,13 +1631,12 @@ impl CatalogController {
 
                     let mut dispatcher = dispatcher.into_active_model();
 
+                    // Only hash dispatcher needs mapping
                     if dispatcher.dispatcher_type.as_ref() == &DispatcherType::Hash {
                         dispatcher.hash_mapping =
                             Set(upstream_dispatcher_mapping.as_ref().map(|m| {
                                 risingwave_meta_model_v2::ActorMapping::from(&m.to_protobuf())
                             }));
-                    } else {
-                        debug_assert!(upstream_dispatcher_mapping.is_none());
                     }
 
                     let mut new_downstream_actor_ids =