|
@@ -376,11 +376,11 @@ model_upload_oss() {
|
|
|
|
|
|
# 移动模型文件
|
|
# 移动模型文件
|
|
# FIXME(zhoutian): 两步文件移动未保证事务
|
|
# FIXME(zhoutian): 两步文件移动未保证事务
|
|
- ${HADOOP} fs -mv ${MODEL_OSS_PATH}/${model_name}_tmp.tar.gz ${MODEL_OSS_PATH}/${model_name}.tar.gz
|
|
|
|
|
|
+ ${HADOOP} fs -cp -f ${MODEL_OSS_PATH}/${model_name}_tmp.tar.gz ${MODEL_OSS_PATH}/${model_name}.tar.gz
|
|
local return_code=$?
|
|
local return_code=$?
|
|
check_run_status ${return_code} ${step_start_time} "模型上传OSS任务" "模型OSS重命名失败"
|
|
check_run_status ${return_code} ${step_start_time} "模型上传OSS任务" "模型OSS重命名失败"
|
|
|
|
|
|
- ${HADOOP} fs -mv ${MODEL_OSS_PATH}/${OSS_CALIBRATION_FILE_NAME}_tmp.txt ${MODEL_OSS_PATH}/${OSS_CALIBRATION_FILE_NAME}.txt
|
|
|
|
|
|
+ ${HADOOP} fs -cp -f ${MODEL_OSS_PATH}/${OSS_CALIBRATION_FILE_NAME}_tmp.txt ${MODEL_OSS_PATH}/${OSS_CALIBRATION_FILE_NAME}.txt
|
|
local return_code=$?
|
|
local return_code=$?
|
|
check_run_status ${return_code} ${step_start_time} "模型上传OSS任务" "模型OSS重命名失败"
|
|
check_run_status ${return_code} ${step_start_time} "模型上传OSS任务" "模型OSS重命名失败"
|
|
|
|
|