开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink的vvp作业表级别血缘显示有问题,怎么回事?

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表字段导致的?

展开
收起
三分钟热度的鱼 2024-07-31 20:41:09 30 0
1 条回答
写回答
取消 提交回答
  • 目前引擎血缘解析是以sink表倒推的,我理解确实是有问题的 ,后面基于作业中心节点的血缘解析优化会进行排期~
    此回答整理自钉群“实时计算Flink产品外部客户交流群”

    2024-07-31 22:46:29
    赞同 6 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载