hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

disable direct load during upgrade

Browse Source
This commit is contained in:
leftgeek 2024-11-27 15:15:05 +00:00 committed by ob-robot
parent 6c4943c4d2
commit 10a7195c2b
1 changed files with 9 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
tools/upgrade/upgrade_checker.py
View File

@ -888,26 +888,15 @@ def is_x86_arch():
# 检查 direct_load 是否已经结束，开启升级之前需要确保没有 direct_load 任务，且升级期间尽量禁止 direct_load 任务
def disable_and_check_direct_load_task(cur, query_cur):
get_version_sql = """select distinct value from GV$OB_PARAMETERS where name='min_observer_version'"""
(version_desc, version_results) = query_cur.exec_query(get_version_sql)
if len(version_results) != 1:
fail_list.append('min_observer_version is not sync')
elif len(version_results[0]) != 1:
fail_list.append('column cnt not match')
else:
min_cluster_version = get_version(version_results[0][0])
if min_cluster_version < get_version("4.3.3.0"):
# 通过配置项关闭 direct_load
set_parameter(cur, '_ob_enable_direct_load', 'False')
# 等待 5s，确保没有导入任务
time.sleep(5)
sql = """select count(1) from __all_virtual_load_data_stat"""
(desc, results) = query_cur.exec_query(sql)
if 0 != results[0][0]:
fail_list.append("There are direct load task in progress")
logging.info('check direct load task execut status success')
else:
logging.info('min cluster version is greater than 4.3.3, no need to disable and check direct load task')
# 通过配置项关闭 direct_load
set_parameter(cur, '_ob_enable_direct_load', 'False')
# 等待 5s，确保没有导入任务
time.sleep(5)
sql = """select count(1) from __all_virtual_load_data_stat"""
(desc, results) = query_cur.exec_query(sql)
if 0 != results[0][0]:
fail_list.append("There are direct load task in progress")
logging.info('check direct load task execut status success')
# 检查cs_encoding格式是否兼容，对小于4.3.3版本的cpu不支持avx2指令集的集群，我们要求升级前schema上不存在cs_encoding的存储格式
# 注意：这里对混布集群 / schema上row_format进行了ddl变更的场景无法做到完全的防御