From 6e7c440fae63a0563879afe6cc9c50ff6883e395 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" <41898282+github-actions[bot]@users.noreply.github.com> Date: Thu, 24 Oct 2024 20:17:26 +0800 Subject: [PATCH] fix(batch): warn when fragment mapping not found (#19105) (#19109) Co-authored-by: zwang28 <70626450+zwang28@users.noreply.github.com> Co-authored-by: Noel Kwan --- src/batch/src/worker_manager/worker_node_manager.rs | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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"); } }; }