diff --git a/server/src/handlers/http/logstream.rs b/server/src/handlers/http/logstream.rs index 89d5b4cdb..f82e44ef4 100644 --- a/server/src/handlers/http/logstream.rs +++ b/server/src/handlers/http/logstream.rs @@ -284,7 +284,7 @@ pub async fn get_stats(req: HttpRequest) -> Result let stats = stats::get_current_stats(&stream_name, "json") .ok_or(StreamError::StreamNotFound(stream_name.clone()))?; - let ingestor_stats = if CONFIG.parseable.mode == Mode::Query { + let ingester_stats = if CONFIG.parseable.mode == Mode::Query { Some(query_server::QueryServer::fetch_stats_from_ingesters(&stream_name).await?) } else { None @@ -336,9 +336,9 @@ pub async fn get_stats(req: HttpRequest) -> Result } }; - let stats = if let Some(mut ingestor_stats) = ingestor_stats { - ingestor_stats.push(stats); - QueryServer::merge_quried_stats(ingestor_stats) + let stats = if let Some(mut ingester_stats) = ingester_stats { + ingester_stats.push(stats); + QueryServer::merge_quried_stats(ingester_stats) } else { stats }; diff --git a/server/src/handlers/http/modal/query_server.rs b/server/src/handlers/http/modal/query_server.rs index 6b8c8841a..07b23286f 100644 --- a/server/src/handlers/http/modal/query_server.rs +++ b/server/src/handlers/http/modal/query_server.rs @@ -166,8 +166,6 @@ impl QueryServer { .map(|x| serde_json::from_slice::(x).unwrap_or_default()) .collect_vec(); - // TODO: add validation logic here - // validate the ingester metadata Ok(arr) }