From bee0c2b815ce1a5474da9f8c5dd950c511384752 Mon Sep 17 00:00:00 2001
From: Shanicky Chen <>
Date: Thu, 20 Jun 2024 17:50:02 +0800
Subject: [PATCH] Add unwrap to to_worker_slot on stream.rs:205

---
 src/meta/src/model/stream.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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()
                         })
                     });