From 583a20e6af0621869503fd342305ae790972bc37 Mon Sep 17 00:00:00 2001 From: Nikhil Sinha Date: Sun, 1 Sep 2024 11:49:51 +0530 Subject: [PATCH] fix: delete hot tier with stream when DELETE /logstream/{stream-name} is called, check if hot tier exists, if yes, delete the hot tier as well. --- server/src/handlers/http/logstream.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/server/src/handlers/http/logstream.rs b/server/src/handlers/http/logstream.rs index 87c38aeea..41cde6fb6 100644 --- a/server/src/handlers/http/logstream.rs +++ b/server/src/handlers/http/logstream.rs @@ -77,6 +77,12 @@ pub async fn delete(req: HttpRequest) -> Result { ) } + if let Some(hot_tier_manager) = HotTierManager::global() { + if hot_tier_manager.check_stream_hot_tier_exists(&stream_name) { + hot_tier_manager.delete_hot_tier(&stream_name).await?; + } + } + let ingestor_metadata = super::cluster::get_ingestor_info().await.map_err(|err| { log::error!("Fatal: failed to get ingestor info: {:?}", err); StreamError::from(err)