diff --git a/src/sql/engine/cmd/ob_tenant_executor.cpp b/src/sql/engine/cmd/ob_tenant_executor.cpp index 150629736..a389e5fbc 100644 --- a/src/sql/engine/cmd/ob_tenant_executor.cpp +++ b/src/sql/engine/cmd/ob_tenant_executor.cpp @@ -382,8 +382,8 @@ int check_sys_var_options(ObExecContext &ctx, int64_t sys_var_val_length = OB_MAX_SYS_VAR_VAL_LENGTH; if (set_var.var_name_ == OB_SV_TCP_INVITED_NODES) { uint64_t data_version = 0; - if (OB_FAIL(GET_MIN_DATA_VERSION(set_var.actual_tenant_id_, data_version))) { - LOG_WARN("fail to get sys data version", KR(ret)); + if (OB_FAIL(GET_MIN_DATA_VERSION(session->get_effective_tenant_id(), data_version))) { + LOG_WARN("fail to get tenant data version", KR(ret)); } else if (data_version >= DATA_VERSION_4_2_1_1) { sys_var_val_length = OB_MAX_TCP_INVITED_NODES_LENGTH; } diff --git a/src/sql/engine/cmd/ob_variable_set_executor.cpp b/src/sql/engine/cmd/ob_variable_set_executor.cpp index 8e6e25378..d80ebcc44 100644 --- a/src/sql/engine/cmd/ob_variable_set_executor.cpp +++ b/src/sql/engine/cmd/ob_variable_set_executor.cpp @@ -720,7 +720,7 @@ int ObVariableSetExecutor::update_global_variables(ObExecContext &ctx, if (set_var.var_name_ == OB_SV_TCP_INVITED_NODES) { uint64_t data_version = 0; if (OB_FAIL(GET_MIN_DATA_VERSION(set_var.actual_tenant_id_, data_version))) { - LOG_WARN("fail to get sys data version", KR(ret)); + LOG_WARN("fail to get tenant data version", KR(ret)); } else if (data_version >= DATA_VERSION_4_2_1_1) { sys_var_val_length = OB_MAX_TCP_INVITED_NODES_LENGTH; } diff --git a/src/sql/engine/expr/ob_expr_get_sys_var.cpp b/src/sql/engine/expr/ob_expr_get_sys_var.cpp index 1fd7c3076..a495adec8 100644 --- a/src/sql/engine/expr/ob_expr_get_sys_var.cpp +++ b/src/sql/engine/expr/ob_expr_get_sys_var.cpp @@ -84,7 +84,7 @@ int ObExprGetSysVar::calc_result_type2(ObExprResType &type, if (0 == var_name.compare(OB_SV_TCP_INVITED_NODES)) { uint64_t data_version = 0; if (OB_FAIL(GET_MIN_DATA_VERSION(session->get_effective_tenant_id(), data_version))) { - LOG_WARN("fail to get sys data version", KR(ret)); + LOG_WARN("fail to get tenant data version", KR(ret)); } else if (data_version >= DATA_VERSION_4_2_1_1) { sys_var_val_length = OB_MAX_TCP_INVITED_NODES_LENGTH; }