From f3f2d956d727afa5a183dfb69c65c39d39ecc90d Mon Sep 17 00:00:00 2001
From: Shanicky Chen <peng@risingwave-labs.com>
Date: Tue, 23 Jul 2024 15:47:02 +0800
Subject: [PATCH] Optimize worker_id retrieval in CreateStreamingJobCommandInfo

---
 src/meta/src/barrier/command.rs | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/meta/src/barrier/command.rs b/src/meta/src/barrier/command.rs
index f394a953b997..2c65f467b4a9 100644
--- a/src/meta/src/barrier/command.rs
+++ b/src/meta/src/barrier/command.rs
@@ -174,9 +174,7 @@ impl CreateStreamingJobCommandInfo {
                                     .actor_status
                                     .get(&actor.actor_id)
                                     .expect("should exist")
-                                    .get_parallel_unit()
-                                    .expect("should set")
-                                    .worker_node_id,
+                                    .worker_id(),
                             )
                         })
                         .collect(),