fix(meta): expired RiseCtl worker causes meta panics (#5212)

* fix ctl ttl causes meta panic * refactor Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
risingwavelabs · Sep 8, 2022 · 761b1ba · 761b1ba
1 parent 828fa0d
commit 761b1ba
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/src/meta/src/manager/cluster.rs b/src/meta/src/manager/cluster.rs
@@ -276,11 +276,18 @@ where
                 for (worker_id, key) in workers_to_delete {
                     match cluster_manager.delete_worker_node(key.clone()).await {
                         Ok(worker_type) => {
-                            cluster_manager
-                                .env
-                                .notification_manager()
-                                .delete_sender(worker_type, WorkerKey(key.clone()))
-                                .await;
+                            match worker_type {
+                                WorkerType::Frontend
+                                | WorkerType::ComputeNode
+                                | WorkerType::Compactor => {
+                                    cluster_manager
+                                        .env
+                                        .notification_manager()
+                                        .delete_sender(worker_type, WorkerKey(key.clone()))
+                                        .await
+                                }
+                                _ => {}
+                            };
                             tracing::warn!(
                                 "Deleted expired worker {} {:#?}, current timestamp {}",
                                 worker_id,