From e93e83419c2296578b51a639edd658e83f5bc189 Mon Sep 17 00:00:00 2001 From: Nikhil Sinha Date: Mon, 24 Nov 2025 17:22:57 -0800 Subject: [PATCH 1/2] chore: remove pmeta ingestion from OSS --- src/handlers/http/modal/query_server.rs | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/src/handlers/http/modal/query_server.rs b/src/handlers/http/modal/query_server.rs index 5afa0459a..516c05beb 100644 --- a/src/handlers/http/modal/query_server.rs +++ b/src/handlers/http/modal/query_server.rs @@ -20,7 +20,7 @@ use std::sync::Arc; use std::thread; use crate::handlers::airplane; -use crate::handlers::http::cluster::{self, init_cluster_metrics_schedular}; +use crate::handlers::http::cluster::{self}; use crate::handlers::http::middleware::{DisAllowRootUser, RouteExt}; use crate::handlers::http::modal::initialize_hot_tier_metadata_on_startup; use crate::handlers::http::{MAX_EVENT_PAYLOAD_SIZE, logstream}; @@ -37,7 +37,6 @@ use actix_web_prometheus::PrometheusMetrics; use async_trait::async_trait; use bytes::Bytes; use tokio::sync::{OnceCell, oneshot}; -use tracing::info; use crate::Server; use crate::parseable::PARSEABLE; @@ -130,10 +129,6 @@ impl ParseableServer for QueryServer { analytics::init_analytics_scheduler()?; } - if init_cluster_metrics_schedular().is_ok() { - info!("Cluster metrics scheduler started successfully"); - } - // local sync on init let startup_sync_handle = tokio::spawn(async { if let Err(e) = sync_start().await { @@ -141,7 +136,6 @@ impl ParseableServer for QueryServer { } }); if let Some(hot_tier_manager) = HotTierManager::global() { - hot_tier_manager.put_internal_stream_hot_tier().await?; // Initialize hot tier metadata files for streams that have hot tier configuration // but don't have local hot tier metadata files yet if let Err(e) = initialize_hot_tier_metadata_on_startup(hot_tier_manager).await { From d85ecf88b4a0132268d6d24464c03f453ff14b8e Mon Sep 17 00:00:00 2001 From: Nikhil Sinha Date: Mon, 24 Nov 2025 17:57:55 -0800 Subject: [PATCH 2/2] deepsource fix --- src/handlers/http/modal/query_server.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/handlers/http/modal/query_server.rs b/src/handlers/http/modal/query_server.rs index 516c05beb..f1a4249c7 100644 --- a/src/handlers/http/modal/query_server.rs +++ b/src/handlers/http/modal/query_server.rs @@ -20,7 +20,7 @@ use std::sync::Arc; use std::thread; use crate::handlers::airplane; -use crate::handlers::http::cluster::{self}; +use crate::handlers::http::cluster; use crate::handlers::http::middleware::{DisAllowRootUser, RouteExt}; use crate::handlers::http::modal::initialize_hot_tier_metadata_on_startup; use crate::handlers::http::{MAX_EVENT_PAYLOAD_SIZE, logstream};