Skip to content

Commit 086bd8a

Browse files
changed validation for internal stream in set hot tier
1 parent fc06beb commit 086bd8a

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

server/src/handlers/http/logstream.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -958,7 +958,7 @@ pub async fn put_stream_hot_tier(
958958
return Err(StreamError::StreamNotFound(stream_name));
959959
}
960960

961-
if stream_name.eq(INTERNAL_STREAM_NAME) {
961+
if STREAM_INFO.stream_type(&stream_name).unwrap() == StreamType::Internal.to_string() {
962962
return Err(StreamError::Custom {
963963
msg: "Hot tier can not be updated for internal stream".to_string(),
964964
status: StatusCode::BAD_REQUEST,

server/src/handlers/http/modal/query_server.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,6 @@ impl QueryServer {
195195
if let Some(hot_tier_manager) = HotTierManager::global() {
196196
hot_tier_manager.put_internal_stream_hot_tier().await?;
197197
hot_tier_manager.download_from_s3()?;
198-
199198
};
200199
let (localsync_handler, mut localsync_outbox, localsync_inbox) =
201200
sync::run_local_sync().await;

0 commit comments

Comments
 (0)