diff --git a/src/share/system_variable/ob_system_variable_init.cpp b/src/share/system_variable/ob_system_variable_init.cpp index 54d71872d1..1fe9db2447 100644 --- a/src/share/system_variable/ob_system_variable_init.cpp +++ b/src/share/system_variable/ob_system_variable_init.cpp @@ -2394,11 +2394,11 @@ static struct VarsInit{ }(); [&] (){ - ObSysVars[168].default_value_ = "0" ; + ObSysVars[168].default_value_ = "1" ; ObSysVars[168].info_ = "enable batching of the RHS IO in NLJ" ; ObSysVars[168].name_ = "_nlj_batching_enabled" ; ObSysVars[168].data_type_ = ObIntType ; - ObSysVars[168].flags_ = ObSysVarFlag::GLOBAL_SCOPE | ObSysVarFlag::SESSION_SCOPE | ObSysVarFlag::NEED_SERIALIZE | ObSysVarFlag::INVISIBLE | ObSysVarFlag::INFLUENCE_PLAN ; + ObSysVars[168].flags_ = ObSysVarFlag::GLOBAL_SCOPE | ObSysVarFlag::SESSION_SCOPE | ObSysVarFlag::QUERY_SENSITIVE | ObSysVarFlag::NEED_SERIALIZE | ObSysVarFlag::INVISIBLE | ObSysVarFlag::INFLUENCE_PLAN ; ObSysVars[168].id_ = SYS_VAR__NLJ_BATCHING_ENABLED ; cur_max_var_id = MAX(cur_max_var_id, static_cast(SYS_VAR__NLJ_BATCHING_ENABLED)) ; ObSysVarsIdToArrayIdx[SYS_VAR__NLJ_BATCHING_ENABLED] = 168 ; diff --git a/src/share/system_variable/ob_system_variable_init.json b/src/share/system_variable/ob_system_variable_init.json index f43a23243f..4f73d6f463 100644 --- a/src/share/system_variable/ob_system_variable_init.json +++ b/src/share/system_variable/ob_system_variable_init.json @@ -2409,11 +2409,11 @@ "_nlj_batching_enabled": { "id": 10080, "name": "_nlj_batching_enabled", - "default_value": "0", + "default_value": "1", "base_value": "1", "data_type": "bool", "info": "enable batching of the RHS IO in NLJ", - "flags": "GLOBAL | SESSION | NEED_SERIALIZE | INVISIBLE | INFLUENCE_PLAN", + "flags": "GLOBAL | SESSION | QUERY_SENSITIVE| NEED_SERIALIZE | INVISIBLE | INFLUENCE_PLAN", "publish_version": "", "info_cn": "", "background_cn": "",