Add unwrap to to_worker_slot on stream.rs:205

risingwavelabs · Jun 20, 2024 · bee0c2b · bee0c2b
1 parent 9734c9a
commit bee0c2b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/meta/src/model/stream.rs b/src/meta/src/model/stream.rs
@@ -205,7 +205,7 @@ impl MetadataModel for TableFragments {
                             risingwave_common::hash::ParallelUnitMapping::from_protobuf(
                                 &vnode_mapping,
                             )
-                            .to_worker_slot(&parallel_unit_to_worker)
+                            .to_worker_slot(&parallel_unit_to_worker).unwrap()
                             .to_protobuf()
                         })
                     });