ps做网站头部的图,做俄罗斯网站,wordpress伪静态html,外包小程序一位神州的正式员工#xff08;没错#xff0c;就是之前文章中出现的实习生#xff09;#xff1a;一闪#xff0c;你今年涨工资了吗#xff1f; 一闪#xff1a;mad#xff0c;一年辛苦到头只涨了500米
神州员工#xff1a;你去年绩效不是优秀吗#xff0c;怎么就涨…一位神州的正式员工没错就是之前文章中出现的实习生一闪你今年涨工资了吗 一闪mad一年辛苦到头只涨了500米
神州员工你去年绩效不是优秀吗怎么就涨了500米还没我零头多
一闪放肆
听说是当时招进来开的工资太高....导致涨薪的时候人资不通过....最后只涨了这么点..... 一闪表示不理解但是尊重
---------------------回到工作
老师傅一闪写Flink SQL的时候遇到个问题来帮我看看。
-- Flink SQL
CREATE TEMPORARY VIEW temp AS
SELECT b.corp_name,a.sale_amount
FROM
(SELECT corp_no,sale_amount -- 销售金额FROM 销售事实表 a -- Flink的流表
) a
inner join
(selectcorp_no,corp_namefrom 门店_维度表 -- Flink的维表group by corp_no,corp_name
) b
on a.corp_no b.corp_no
;
一闪我先来分析一下你这段代码你有一个事实表里面存了公司编号和销售金额。你需要关联维度表来取到公司名称不过的维度表原来是门店维度所以你写了一个子查询对该表里面的公司进行去重确保公司关联公司数据不会重复。
老师傅没错没错就是这个需求你来帮我看看代码上有啥问题没有
一闪好像没啥问题啊至少运行不会报错现在是有啥病症吗
老师傅每次任务重启的时候数据都没问题但是过了一段时间之后数据就不准了估计只能坚挺48小时不到......我为什么要用坚挺这个词 一闪作为一名数据开发的资深叼毛对数据的敏感性突现48小时不到....并且刚重启时是正常的理性分析一波我猜问题应该是出在维度数据上...但是flink的维表一般是不可能数据过期的啊
------------去厕所放空一下
想明白了问题应该在Flink的过期参数上table.exec.state.ttl这个参数正好是36小时小于老师傅说的48小时。
------------裤子一提冲出厕所
一闪默认流数据过期时间36小时所以你的表数据过期了导致关联的时候出了问题。既然你说任务刚重启时没有问题我理解事实表的逻辑没有问题所以BGM起心机之蛙一直摸你肚子凶手就是你的子查询让维表被系统解析成了流表36小时后自动失效导致结果数据出现问题。
老师傅卧槽牛b那么大师我该怎么改呢要不我把参数改成永不失效
一闪流汗亲建议你直接做一张公司的维度表吧你如果把参数改成永不失效我相信代码和你都可以跑了。
