fix unwrap

risingwavelabs · Feb 4, 2024 · 1887f62 · 1887f62
1 parent 4698811
commit 1887f62
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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!(