@@ -20,7 +20,7 @@ use std::sync::Arc;
2020use std:: thread;
2121
2222use crate :: handlers:: airplane;
23- use crate :: handlers:: http:: cluster:: { self , init_cluster_metrics_schedular } ;
23+ use crate :: handlers:: http:: cluster;
2424use crate :: handlers:: http:: middleware:: { DisAllowRootUser , RouteExt } ;
2525use crate :: handlers:: http:: modal:: initialize_hot_tier_metadata_on_startup;
2626use crate :: handlers:: http:: { MAX_EVENT_PAYLOAD_SIZE , logstream} ;
@@ -37,7 +37,6 @@ use actix_web_prometheus::PrometheusMetrics;
3737use async_trait:: async_trait;
3838use bytes:: Bytes ;
3939use tokio:: sync:: { OnceCell , oneshot} ;
40- use tracing:: info;
4140
4241use crate :: Server ;
4342use crate :: parseable:: PARSEABLE ;
@@ -130,18 +129,13 @@ impl ParseableServer for QueryServer {
130129 analytics:: init_analytics_scheduler ( ) ?;
131130 }
132131
133- if init_cluster_metrics_schedular ( ) . is_ok ( ) {
134- info ! ( "Cluster metrics scheduler started successfully" ) ;
135- }
136-
137132 // local sync on init
138133 let startup_sync_handle = tokio:: spawn ( async {
139134 if let Err ( e) = sync_start ( ) . await {
140135 tracing:: warn!( "local sync on server start failed: {e}" ) ;
141136 }
142137 } ) ;
143138 if let Some ( hot_tier_manager) = HotTierManager :: global ( ) {
144- hot_tier_manager. put_internal_stream_hot_tier ( ) . await ?;
145139 // Initialize hot tier metadata files for streams that have hot tier configuration
146140 // but don't have local hot tier metadata files yet
147141 if let Err ( e) = initialize_hot_tier_metadata_on_startup ( hot_tier_manager) . await {
0 commit comments