diff --git a/src/meta/src/barrier/command.rs b/src/meta/src/barrier/command.rs
index f394a953b997f..2c65f467b4a98 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(),