From 1887f62da5e2ebfd9e0b47860e3afbc75005aedf Mon Sep 17 00:00:00 2001 From: William Wen Date: Mon, 5 Feb 2024 01:19:13 +0800 Subject: [PATCH] fix unwrap --- src/meta/src/manager/metadata.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/meta/src/manager/metadata.rs b/src/meta/src/manager/metadata.rs index ff55a0bad4f98..69a01dafb0f27 100644 --- a/src/meta/src/manager/metadata.rs +++ b/src/meta/src/manager/metadata.rs @@ -102,7 +102,7 @@ impl ActiveStreamingWorkerNodes { match notification { LocalNotification::WorkerNodeDeleted(worker) => { let is_streaming_compute_node = worker.r#type == WorkerType::ComputeNode as i32 - || worker.property.as_ref().unwrap().is_streaming; + && worker.property.as_ref().unwrap().is_streaming; let Some(prev_worker) = self.worker_nodes.remove(&worker.id) else { if is_streaming_compute_node { warn!(