diff --git a/src/meta/src/model/stream.rs b/src/meta/src/model/stream.rs
index 73ac15b3e11f4..828f5590dab5a 100644
--- 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()
                         })
                     });