diff --git a/src/meta/src/manager/session_params.rs b/src/meta/src/manager/session_params.rs index b8fca4f47043a..662eae162a92d 100644 --- a/src/meta/src/manager/session_params.rs +++ b/src/meta/src/manager/session_params.rs @@ -24,7 +24,7 @@ use tracing::info; use crate::model::{ValTransaction, VarTransaction}; use crate::storage::{MetaStore, MetaStoreRef, Snapshot, Transaction}; -use crate::{MetaError, MetaResult}; +use crate::MetaResult; pub type SessionParamsManagerRef = Arc; @@ -48,13 +48,13 @@ impl SessionParamsManager { let params = if cluster_first_launch { init_params } else if let Some(params) = - ::get(&meta_store, init_params).await? + ::get(&meta_store, init_params.clone()).await? { params } else { - return Err(MetaError::system_params( - "cluster is not newly created but no session parameters can be found", - )); + tracing::warn!("Cluster is not newly created but no session parameters can be found. \ + Possibly caused by upgrading from a version where system wide session parameter was not supported"); + init_params }; info!(?params, "session parameters");