Flink的vvp作业表级别血缘显示有问题,怎么回事?
insert into dws_trans_log_dtl_top_lg_transfer_detail
select a.create_time,
a.acct_transfer_ord_id,
a.transfer_acct_detail_id,
b.hf_seq_id,
usr_indv_base_info.cert_no_mask,
usr_indv_base_info.cert_no_cipher,
usr_indv_base_info.mobile_no_mask,
usr_indv_base_info.mobile_no_cipher
from top_acct_transfer_detail a
left join top_acct_transfer b on a.acct_transfer_ord_id = b.ord_id
left join dim_top_acct_transfer FOR SYSTEM_TIME AS OF a.proctime AS dim_b on b.org_ord_id = dim_b.ord_id
left join spin_ssp_prod_usr_indv_base_info FOR SYSTEM_TIME AS OF a.proctime AS usr_indv_base_info on a.in_huifu_id=usr_indv_base_info.huifu_id
where a.transfer_type in ('PAY_CONFIRM','ACCT_PAYMENT','HYC_CFM_TRANS','HYC_ACP_TRANS','LJH_CFM_TRANS','LJH_ACP_TRANS','LJH_FEE_TRANS','LJH_SPLIT_TRANS')
and b.transaction_flag in ('H','L')
本该有4张source table的,只显示了3张,漏了dim_top_acct_transfer表,是不是因为最后写入sink表时没有带上该dim表字段导致的?
目前引擎血缘解析是以sink表倒推的,我理解确实是有问题的 ,后面基于作业中心节点的血缘解析优化会进行排期~
此回答整理自钉群“实时计算Flink产品外部客户交流群”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。