Skip to content

chore: remove pmeta ingestion from OSS #1468

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Nov 25, 2025
Merged

chore: remove pmeta ingestion from OSS #1468

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
e93e834
chore: remove pmeta ingestion from OSS
nikhilsinhaparseable Nov 25, 2025
d85ecf8
deepsource fix
nikhilsinhaparseable Nov 25, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 1 addition & 7 deletions src/handlers/http/modal/query_server.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;
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};
Expand All @@ -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;
Expand Down Expand Up @@ -130,18 +129,13 @@ 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 {
tracing::warn!("local sync on server start failed: {e}");
}
});
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 {
Expand Down
Loading