Skip to content

Commit 008bd7f

Browse files
fix: delete hot tier with stream (#909)
when DELETE /logstream/{stream-name} is called, check if hot tier exists, if yes, delete the hot tier as well.
1 parent 764b259 commit 008bd7f

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

server/src/handlers/http/logstream.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,12 @@ pub async fn delete(req: HttpRequest) -> Result<impl Responder, StreamError> {
7777
)
7878
}
7979

80+
if let Some(hot_tier_manager) = HotTierManager::global() {
81+
if hot_tier_manager.check_stream_hot_tier_exists(&stream_name) {
82+
hot_tier_manager.delete_hot_tier(&stream_name).await?;
83+
}
84+
}
85+
8086
let ingestor_metadata = super::cluster::get_ingestor_info().await.map_err(|err| {
8187
log::error!("Fatal: failed to get ingestor info: {:?}", err);
8288
StreamError::from(err)

0 commit comments

Comments
 (0)