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)