support adjust parallel degree of complement data dag.
This commit is contained in:
@ -828,6 +828,9 @@ DEF_INT(ha_mid_thread_score, OB_TENANT_PARAMETER, "0", "[0,100]",
|
|||||||
DEF_INT(ha_low_thread_score, OB_TENANT_PARAMETER, "0", "[0,100]",
|
DEF_INT(ha_low_thread_score, OB_TENANT_PARAMETER, "0", "[0,100]",
|
||||||
"the current work thread score of high availability low thread. Range: [0,100] in integer. Especially, 0 means default value",
|
"the current work thread score of high availability low thread. Range: [0,100] in integer. Especially, 0 means default value",
|
||||||
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
||||||
|
DEF_INT(ddl_thread_score, OB_TENANT_PARAMETER, "0", "[0,100]",
|
||||||
|
"the current work thread score of ddl thread. Range: [0,100] in integer. Especially, 0 means default value",
|
||||||
|
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
||||||
DEF_INT(minor_compact_trigger, OB_TENANT_PARAMETER, "2", "[0,16]",
|
DEF_INT(minor_compact_trigger, OB_TENANT_PARAMETER, "2", "[0,16]",
|
||||||
"minor_compact_trigger, Range: [0,16] in integer",
|
"minor_compact_trigger, Range: [0,16] in integer",
|
||||||
ObParameterAttr(Section::TENANT, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
ObParameterAttr(Section::TENANT, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
||||||
|
|||||||
@ -1547,6 +1547,7 @@ void ObTenantDagScheduler::reload_config()
|
|||||||
set_thread_score(ObDagPrio::DAG_PRIO_HA_HIGH, tenant_config->ha_high_thread_score);
|
set_thread_score(ObDagPrio::DAG_PRIO_HA_HIGH, tenant_config->ha_high_thread_score);
|
||||||
set_thread_score(ObDagPrio::DAG_PRIO_HA_MID, tenant_config->ha_mid_thread_score);
|
set_thread_score(ObDagPrio::DAG_PRIO_HA_MID, tenant_config->ha_mid_thread_score);
|
||||||
set_thread_score(ObDagPrio::DAG_PRIO_HA_LOW, tenant_config->ha_low_thread_score);
|
set_thread_score(ObDagPrio::DAG_PRIO_HA_LOW, tenant_config->ha_low_thread_score);
|
||||||
|
set_thread_score(ObDagPrio::DAG_PRIO_DDL, tenant_config->ddl_thread_score);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -56,6 +56,7 @@ data_dir
|
|||||||
data_disk_usage_limit_percentage
|
data_disk_usage_limit_percentage
|
||||||
data_storage_error_tolerance_time
|
data_storage_error_tolerance_time
|
||||||
data_storage_warning_tolerance_time
|
data_storage_warning_tolerance_time
|
||||||
|
ddl_thread_score
|
||||||
dead_socket_detection_timeout
|
dead_socket_detection_timeout
|
||||||
debug_sync_timeout
|
debug_sync_timeout
|
||||||
default_auto_increment_mode
|
default_auto_increment_mode
|
||||||
|
|||||||
Reference in New Issue
Block a user