开发者社区 > 大数据与机器学习 > 大数据开发治理DataWorks > 正文

前俩天跑的没问题,今天跑的突然出问题了,数据集也是之前的没有动,有没有大佬帮忙看看是什么原因,应该怎

2024-05-24 16:48:24 INFO Current task status:RUNNING
2024-05-24 16:48:24 INFO Start execute shell on node m11b01104.cloud.b19.am11.8011.
2024-05-24 16:48:24 INFO Current working dir /home/admin/alisatasknode/taskinfo/20240524/dide/16/48/21/d4690l3qps1t9yf4g1day3wi
2024-05-24 16:48:24 INFO Full Command ..
2024-05-24 16:48:24 INFO -------------------------
2024-05-24 16:48:24 INFO /opt/taobao/tbdpapp/odpswrapper/odpswrapper.py -M /home/admin/alisatasknode/taskinfo//20240524/dide/16/48/21/d4690l3qps1t9yf4g1day3wi//main.sql last_mn1=202401 --skiphooks 1> /home/admin/alisatasknode/taskinfo//20240524/dide/16/48/21/d4690l3qps1t9yf4g1day3wi/T3_0000017314.data
2024-05-24 16:48:24 INFO -------------------------
2024-05-24 16:48:24 INFO List of passing environment ..
2024-05-24 16:48:24 INFO -------------------------
2024-05-24 16:48:24 INFO SKYNET_BUSINESS_NAME=:
2024-05-24 16:48:24 INFO SKYNET_PTYPE=10:
2024-05-24 16:48:24 INFO SKYNET_ONDUTY=5235649614954041526:
2024-05-24 16:48:24 INFO SKYNET_SYSTEMID=dev:
2024-05-24 16:48:24 INFO SKYNET_FILEID=921:
2024-05-24 16:48:24 INFO SKYNET_PACKAGEID=YXGS_DEV:
2024-05-24 16:48:24 INFO SKYNET_DIDE_JOBID=42297e2c-f554-4b70-bb72-6dc56377be96:
2024-05-24 16:48:24 INFO SKYNET_ADVANCE_SETTINGS=:
2024-05-24 16:48:24 INFO SKYNET_TENANT_ID=656595127652800:
2024-05-24 16:48:24 INFO SKYNET_NODENAME=llw:
2024-05-24 16:48:24 INFO SKYNET_TASK_HOOK=true:
2024-05-24 16:48:24 INFO ODPS_SQL_RETRY=false:
2024-05-24 16:48:24 INFO SKYNET_MASK_PROJECT=YXGS_DEV:
2024-05-24 16:48:24 INFO SKYNET_TENANTOWNER=11023914623297689:
2024-05-24 16:48:24 INFO SKYNET_ARGS={"dataworks":"dataworks"}:
2024-05-24 16:48:24 INFO IS_NEW_SCHEDULE=true:
2024-05-24 16:48:24 INFO SKYNET_DAGTYPE=110:
2024-05-24 16:48:24 INFO SKYNET_SYSTEM_ENV=dev:
2024-05-24 16:48:24 INFO SKYNET_GMTDATE=20240524:
2024-05-24 16:48:24 INFO SKYNET_BIZDATE=20240524:
2024-05-24 16:48:24 INFO SKYNET_PROJECTID=10014:
2024-05-24 16:48:24 INFO SKYNET_BUSINESS_ID=:
2024-05-24 16:48:24 INFO SKYNET_ARGS_ENABLE=true:
2024-05-24 16:48:24 INFO SKYNET_ACCOUNT_ID=ascm-org-1714623297575:34237:
2024-05-24 16:48:24 INFO SKYNET_MASK_ALL=true:
2024-05-24 16:48:24 INFO LINK_FILE_ID=921:
2024-05-24 16:48:24 INFO TASK_PLUGIN_NAME=ide_odps:
2024-05-24 16:48:24 INFO ALISA_TASK_ID=T3_0000017314:
2024-05-24 16:48:24 INFO ALISA_TASK_EXEC_TARGET=ide_default:
2024-05-24 16:48:24 INFO ALISA_TASK_PRIORITY=0:
2024-05-24 16:48:24 INFO --- Invoking Shell command line now ---
2024-05-24 16:48:24 INFO =================================================================
2024-05-24 16:48:24 config file is ok!!!
2024-05-24 16:48:24 Env ODPS_SQL_RETRY skips SQL retry
2024-05-24 16:48:24 sql:
set SKYNET_ID=-;
set SKYNET_BIZDATE=20240524;
set SKYNET_PACKAGEID=YXGS_DEV;
set SKYNET_CYCTIME=-;
set SKYNET_TASKID=-;
set SKYNET_SYSTEMID=dev;
set SKYNET_PRIORITY=-;
set SKYNET_JOBID=-;
set SKYNET_ONDUTY=5235649614954041526;
set SKYNET_TENANT_ID=656595127652800;
set WRAPPER_SQLSEQ=1;
set WRAPPER_RETRYNUM=1;
set biz_id=-20240524-_-_1_YXGS_DEV_5235649614954041526_656595127652800;
SELECT cc.id
,cc.crm_code
,cc.cost_center_code
,cc.cost_center_name
,cc.eas_cost_center_name
,CASE WHEN cc.is_manual=1 THEN '是'
WHEN cc.is_manual=0 THEN'否'
END as is_manually_modified
,ccParent.cost_center_code as p_cost_center_code
,ccParent.cost_center_name as p_cost_center_name
,CASE WHEN cc.fk_md_id_company=1 THEN '石家庄以岭药业股份有限公司'
WHEN cc.fk_md_id_company=2 THEN'北京以岭药业有限公司'
END as cost_bear_company
,cc.has_child as is_exist_child_node
,CASE WHEN cc.fk_md_id_statistical=2 THEN '区办'
WHEN cc.fk_md_id_statistical=1 THEN'部门'
END as statistical_category
,CASE WHEN cc.is_virtual=0 THEN '否'
WHEN cc.is_virtual=1 THEN'是'
END as is_virtual_cost_center
,CASE WHEN cc.enabled=1 THEN '启用'
WHEN cc.enabled=0 THEN'停用'
END as enable_state
,syuser.username as cost_center_header_code
,syuser.realname as cost_center_header_name
,cc.level as cost_center_level
,dp.org_code as org_structure_code
,dp.depart_name as org_structure_name
,dp.yx_plate_id as dept_code_level1
,dp.yx_plate as dept_name_level1
,dp.yx_two_dept_id as dept_id_level2
,dp.yx_two_dept_code as dept_code_level2
,dp.yx_two_dept as dept_name_level2
,dp.unit_id as dept_id_level3
,dp.unit_code as dept_code_level3
,dp.unit_name as dept_name_level3
,dp.business_unit_id as dept_id_level4
,dp.business_unit_code as dept_code_level4
,business_unit_name as dept_name_level4
,dp.area as region_name
,provincial_area_code as province_area_code
,dp.provincial_area_name as province_area_name
,dp.business_province_code as business_province_code
,dp.business_province_name as business_province_name
,ru.username as chk_point1_code
,ru.realname as chk_point1_name
,uf.username as chk_point2_code
,uf.realname as chk_point2_name
,CASE WHEN dp.fk_md_id_ttribute=1 THEN '总部'
WHEN dp.fk_md_id_ttribute=2 THEN '省区'
END as dept_attributes
,CASE WHEN cc.cbzx_group IS NULL THEN ''
WHEN cc.cbzx_group IS NOT NULL THEN (SELECT sys_dict_item.item_text FROM ods_yxyl_pms_sys_dict_item_mf sys_dict_item LEFT JOIN ods_yxyl_pms_sys_dict_mf sys_dict ON sys_dict.id = sys_dict_item.dict_id WHERE sys_dict.dict_code='BudgetPlate' AND cc.cbzx_group = sys_dict_item.item_value)
END as cost_center_group
,CASE WHEN cc.update_rule IS NULL THEN ''
WHEN cc.update_rule IS NOT NULL THEN (SELECT sys_dict_item.item_text FROM ods_yxyl_pms_sys_dict_item_mf sys_dict_item LEFT JOIN ods_yxyl_pms_sys_dict_mf sys_dict ON sys_dict.id = sys_dict_item.dict_id WHERE sys_dict.dict_code='management_latitude_rule' AND cc.update_rule = sys_dict_item.item_value)
END as update_rule
,CURRENT_TIMESTAMP as etl_time
,cc.yrmn
from tmp_yxyl_cexe_financial_cost_center_report_mf_1 cc
left join tmp_yxyl_cexe_financial_cost_center_report_mf_1 ccParent on cc.parent_id=ccParent.id
left join tmp_yxyl_cexe_financial_cost_center_report_mf_2 dp on cc.fk_department_id_organization =dp.id
left join tmp_yxyl_cexe_financial_cost_center_report_mf_3 syuser on cc.fk_user_id_cost_center_person=syuser.id
left join tmp_yxyl_cexe_financial_cost_center_report_mf_3 ru on cc.fk_user_id_regional=ru.id
left join tmp_yxyl_cexe_financial_cost_center_report_mf_3 uf on cc.fk_user_id_finance=uf.id
LIMIT 10000;
OK
OK
OK
OK
OK
OK
OK
OK
OK
OK
OK
OK
OK
2024-05-24 16:48:24 start to get jobId:
2024-05-24 16:48:24 get jobid:20240524084824847gedjb6l
ID = 20240524084824847gedjb6l
Log view:
http://logview.cn-shijiazhuang-yldt-d01.odps.ops.market-rd.yiling.cn:9000/logview/?h=http://service.cn-shijiazhuang-yldt-d01.odps.ops.market-rd.yiling.cn/api&p=YXGS_DEV&i=20240524084824847gedjb6l&token=aCtDZUUxa1JLTU9BdkQxUHZIUWM3MEdLVTJBPSxPRFBTX09CTzpwNF8yMzU2NDk2MTQ5NTQwNDE1MjYsMTcxOTEzMjUwNCx7IlN0YXRlbWVudCI6W3siQWN0aW9uIjpbIm9kcHM6UmVhZCJdLCJFZmZlY3QiOiJBbGxvdyIsIlJlc291cmNlIjpbImFjczpvZHBzOio6cHJvamVjdHMveXhnc19kZXYvaW5zdGFuY2VzLzIwMjQwNTI0MDg0ODI0ODQ3Z2VkamI2bCJdfV0sIlZlcnNpb24iOiIxIn0=
Job Queueing...
2024-05-24 16:48:29 M1_job_0:0/0/1[RUNNING] M2_job_0:0/0/1[RUNNING] M3_job_0:0/0/1[RUNNING] M4_1_2_3_job_0:0/0/1[WAITING] M8_job_0:0/0/4[RUNNING] R9_8_job_0:0/0/1[WAITING] R5_8_job_0:0/0/1[WAITING] M10_5_9_job_0:0/0/4[WAITING] J6_4_10_job_0:0/0/5[WAITING] R7_6_job_0:0/0/1[WAITING] J11_7_10_job_0:0/0/5[WAITING] R12_11_job_0:0/0/1[WAITING]
2024-05-24 16:48:35 M1_job_0:0/1/1[TERMINATED] M2_job_0:0/1/1[TERMINATED] M3_job_0:0/1/1[TERMINATED] M4_1_2_3_job_0:0/1/1[TERMINATED] M8_job_0:0/4/4[TERMINATED] R9_8_job_0:0/1/1[TERMINATED] R5_8_job_0:0/1/1[TERMINATED] M10_5_9_job_0:0/0/4[RUNNING] J6_4_10_job_0:0/0/5[WAITING] R7_6_job_0:0/0/1[WAITING] J11_7_10_job_0:0/0/5[WAITING] R12_11_job_0:0/0/1[WAITING]

FAILED: ODPS-0130111: Fuxi job failed - Data Set should contains exactly one row

start hook for mask result...
Picked up JAVA_TOOL_OPTIONS: -Duser.timezone=Asia/Shanghai

mask info: ...start to mask data...
mask info: mask cost Time =>0
2024-05-24 16:48:39 INFO =================================================================
2024-05-24 16:48:39 INFO Exit code of the Shell command 100
2024-05-24 16:48:39 INFO --- Invocation of Shell command completed ---
2024-05-24 16:48:39 ERROR Shell run failed!
2024-05-24 16:48:39 ERROR Current task status: ERROR
2024-05-24 16:48:39 INFO Cost time is: 15.014s
/home/admin/alisatasknode/taskinfo//20240524/dide/16/48/21/d4690l3qps1t9yf4g1day3wi/T3_0000017314.log-END-EOF

展开
收起
游客mfyvhqcnbrbhi 2024-05-24 16:53:41 148 0
0 条回答
写回答
取消 提交回答

DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。

热门讨论

热门文章

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载