当在Hive Catalog中执行CTAS时会有概率报错:Table [...] does not exists in database [...],有什么办法解决?

Viewed 3

版本:2.1.8
执行日志如下:
sql:2025-07-10 11:00:34,set enable_nereids_planner=true
queryId:2025-07-10 11:00:34,null,execTime: 0.001s
sql:2025-07-10 11:00:34,set enable_fallback_to_original_planner=false
queryId:2025-07-10 11:00:34,null,execTime: 0.0s
...
sql:2025-07-10 11:00:34,DROP TABLE IF EXISTS hive_lyss.tmp.shadow_tmp_sor_bss_prod_inst_daily_add_01_e
queryId:2025-07-10 11:00:35,null,execTime: 1.195s
sql:2025-07-10 11:00:35,DROP TABLE IF EXISTS hive_lyss.tmp.shadow_tmp_sor_bss_prod_inst_daily_add_02_e
queryId:2025-07-10 11:00:36,null,execTime: 1.002s
...
sql:2025-07-10 11:00:41,REFRESH DATABASE hive_lyss.tmp
queryId:2025-07-10 11:00:41,null,execTime: 0.002s
sql:2025-07-10 11:00:41,CREATE TABLE hive_lyss.tmp.shadow_tmp_sor_bss_prod_inst_daily_add_01_e AS SELECT T.PROD_INST_ID, T.CITY_ID, T.PROD_ID, T.ACC_PROD_INST_ID, T.PROD_USE_TYPE, T.ACC_NUM, T.ACCOUNT, T.PAYMENT_MODE_CD, T.ADDRESS_DESC, T.OWNER_CUST_ID, T.PROD_INST_PWD, T.EXCH_ID, T.ADDRESS_ID, T.REGION_ID, T.LAN_ID, T.ACT_DATE, T.BEGIN_RENT_DATE, T.STOP_RENT_DATE, T.STATUS_CD, T.CREATE_ORG_ID, T.CREATE_STAFF, T.UPDATE_STAFF, T.CREATE_DATE, T.STATUS_DATE, T.UPDATE_DATE, T.FIRST_FINISH_DATE, T.BUSI_MOD_DATE, T.USE_CUST_ID, T.LAST_ORDER_ITEM_ID, T.REMARK, T.POINT_OWNER_ID, T.PROD_FUNC_TYPE, T.EXT_PROD_INST_ID, T.OUTER_PROD_INST_ID, CAST(NULL AS STRING) AS OGG_OPER_FLAG FROM (SELECT T.prod_inst_id, T.prod_id, T.acc_prod_inst_id, T.prod_use_type, T.acc_num, T.account, T.payment_mode_cd, T.address_desc, T.owner_cust_id, T.prod_inst_pwd, T.exch_id, T.address_id, T.region_id, T.lan_id, T.act_date, T.begin_rent_date, T.stop_rent_date, T.status_cd, T.create_org_id, T.create_staff, T.update_staff, T.create_date, T.status_date, T.update_date, T.first_finish_date, T.busi_mod_date, T.use_cust_id, T.last_order_item_id, T.remark, T.point_owner_id, T.prod_func_type, T.ext_prod_inst_id, T.outer_prod_inst_id, T.grp_prod_nbr, T.clndr_dt_id, B.CITY_ID, ROW_NUMBER() OVER (PARTITION BY T.PROD_INST_ID ORDER BY T.UPDATE_DATE DESC) AS RN FROM hive_lyss.ssa.crm_cus_inst_prod_inst AS T INNER JOIN hive_lyss.sor.common_region_city AS B ON T.REGION_ID = B.COMMON_REGION_ID WHERE T.CLNDR_DT_ID >= REGEXP_REPLACE(CAST(DATE_ADD(CONCAT_WS('-', SUBSTRING(20250709, 1, 4), SUBSTRING(20250709, 5, 2), SUBSTRING(20250709, 7, 2)), -1) AS DATE), '-', '') AND (B.CITY_ID = 'E' OR 'Z' = 'E')) AS T WHERE T.RN = 1
queryId:2025-07-10 11:06:50,null,execTime: 369.079s
sql:2025-07-10 11:06:50,CREATE TABLE hive_lyss.tmp.shadow_tmp_sor_bss_prod_inst_daily_add_02_e AS SELECT T.PROD_INST_ID, T.CITY_ID, T.PROD_ID, T.ACC_PROD_INST_ID, T.PROD_USE_TYPE, T.ACC_NUM, T.ACCOUNT, T.PAYMENT_MODE_CD, T.ADDRESS_DESC, T.OWNER_CUST_ID, T.PROD_INST_PWD, T.EXCH_ID, T.ADDRESS_ID, T.REGION_ID, T.LAN_ID, T.ACT_DATE, T.BEGIN_RENT_DATE, T.STOP_RENT_DATE, T.STATUS_CD, T.CREATE_ORG_ID, T.CREATE_STAFF, T.UPDATE_STAFF, T.CREATE_DATE, T.STATUS_DATE, T.UPDATE_DATE, T.FIRST_FINISH_DATE, T.BUSI_MOD_DATE, T.USE_CUST_ID, T.LAST_ORDER_ITEM_ID, T.REMARK, T.POINT_OWNER_ID, T.PROD_FUNC_TYPE, T.EXT_PROD_INST_ID, T.OUTER_PROD_INST_ID, CAST(NULL AS STRING) AS OGG_OPER_FLAG FROM (SELECT T.prod_inst_id, T.prod_id, T.acc_prod_inst_id, T.prod_use_type, T.acc_num, T.account, T.payment_mode_cd, T.address_desc, T.owner_cust_id, T.prod_inst_pwd, T.exch_id, T.address_id, T.region_id, T.lan_id, T.act_date, T.begin_rent_date, T.stop_rent_date, T.status_cd, T.create_org_id, T.create_staff, T.update_staff, T.create_date, T.status_date, T.update_date, T.first_finish_date, T.busi_mod_date, T.use_cust_id, T.last_order_item_id, T.remark, T.point_owner_id, T.prod_func_type, T.ext_prod_inst_id, T.transfer_date, T.outer_prod_inst_id, T.grp_prod_nbr, T.clndr_dt_id, B.CITY_ID, ROW_NUMBER() OVER (PARTITION BY T.PROD_INST_ID ORDER BY T.UPDATE_DATE DESC) AS RN FROM hive_lyss.ssa.crm_cus_inst_prod_inst_his AS T INNER JOIN hive_lyss.sor.common_region_city AS B ON T.REGION_ID = B.COMMON_REGION_ID WHERE T.CLNDR_DT_ID >= REGEXP_REPLACE(CAST(DATE_ADD(CONCAT_WS('-', SUBSTRING(20250709, 1, 4), SUBSTRING(20250709, 5, 2), SUBSTRING(20250709, 7, 2)), -1) AS DATE), '-', '') AND (B.CITY_ID = 'E' OR 'Z' = 'E') AND T.STATUS_CD LIKE '11%') AS T WHERE T.RN = 1
ִ��ʧ�ܣ�ʧ��ԭ��errCode = 2, detailMessage = Failed to execute CTAS Reason: Table [shadow_tmp_sor_bss_prod_inst_daily_add_02_e] does not exist in database [tmp].

0 Answers