diff --git a/src/batch/src/worker_manager/worker_node_manager.rs b/src/batch/src/worker_manager/worker_node_manager.rs index 80cd2806f2b6..5911211b8ad7 100644 --- a/src/batch/src/worker_manager/worker_node_manager.rs +++ b/src/batch/src/worker_manager/worker_node_manager.rs @@ -222,10 +222,7 @@ impl WorkerNodeManager { // Do nothing for placeholder fragment. } None => { - panic!( - "Streaming vnode mapping not found for fragment_id: {}", - fragment_id - ) + tracing::warn!(fragment_id, "Streaming vnode mapping not found"); } }; }