diff --git a/src/datanode/src/region_server/registrations.rs b/src/datanode/src/region_server/registrations.rs index 2eb86a9ff7..568ccc8c2b 100644 --- a/src/datanode/src/region_server/registrations.rs +++ b/src/datanode/src/region_server/registrations.rs @@ -21,7 +21,7 @@ use common_query::request::{ DynFilterPayload, INITIAL_REMOTE_DYN_FILTER_REGISTRATIONS_EXTENSION_KEY, InitialDynFilterReg, InitialDynFilterRegs, REMOTE_DYN_FILTER_PAYLOAD_MAX_BYTES, }; -use common_telemetry::warn; +use common_telemetry::{debug, warn}; use dashmap::DashMap; use datafusion::arrow::datatypes::{Schema, SchemaRef}; use datafusion::execution::{SessionStateBuilder, TaskContext}; @@ -557,7 +557,7 @@ pub(super) fn apply_remote_dyn_filter_update( REMOTE_DYN_FILTER_PAYLOAD_BYTES.observe(payload.len() as f64); let Some(query_regs) = regs_by_query.get_query(query_id) else { - warn!( + debug!( "Ignored remote dynamic filter update without query registration, query_id: {}, filter_id: {}", query_id, filter_id ); @@ -568,7 +568,7 @@ pub(super) fn apply_remote_dyn_filter_update( let mut query_regs = query_regs.lock().unwrap(); let Some(registered) = query_regs.get_mut(filter_id) else { - warn!( + debug!( "Ignored remote dynamic filter update without filter registration, query_id: {}, filter_id: {}", query_id, filter_id ); @@ -589,7 +589,7 @@ pub(super) fn unregister_remote_dyn_filter( filter_id: &RemoteDynFilterId, ) -> RemoteDynFilterUpdateOutcome { let Some(query_regs) = regs_by_query.get_query(query_id) else { - warn!( + debug!( "Ignored remote dynamic filter unregister without query registration, query_id: {}, filter_id: {}", query_id, filter_id ); @@ -601,7 +601,7 @@ pub(super) fn unregister_remote_dyn_filter( let (registered, should_remove_query) = { let mut locked = query_regs.lock().unwrap(); let Some(registered) = locked.remove(filter_id) else { - warn!( + debug!( "Ignored remote dynamic filter unregister without filter registration, query_id: {}, filter_id: {}", query_id, filter_id ); diff --git a/src/datanode/src/region_server/remote_dyn_filter.rs b/src/datanode/src/region_server/remote_dyn_filter.rs index 1317dc0502..529b1b23b3 100644 --- a/src/datanode/src/region_server/remote_dyn_filter.rs +++ b/src/datanode/src/region_server/remote_dyn_filter.rs @@ -225,8 +225,7 @@ impl RegionServer { ) { if matches!( outcome, - RemoteDynFilterUpdateOutcome::MissingRegistration - | RemoteDynFilterUpdateOutcome::AlreadyComplete + RemoteDynFilterUpdateOutcome::AlreadyComplete | RemoteDynFilterUpdateOutcome::PayloadTooLarge | RemoteDynFilterUpdateOutcome::DecodeFailed ) {