MaxCompute odps天任务依赖小时任务,天任务是当天跑昨天数据,昨天的数据都是小时任务。发现昨天的小时任务还没完全跑完,天任务就已经开始运行了,导致天任务获取的数据不完整。
昨天的00-23,24个小时分区数据运行完成之后,天任务再运行。保证天任务的数据是完整的。
...
要保障小时任务全部运行完再运行天任务的话,可以在小时任务节点和天任务节点中间再加一个节点,这个节点就用来检测小时任务是否已经全部运行完成,或者24个小时任务也可以直接用循环节点来实现,这样就可以保证一定是循环完所有小时节点才会触发天任务的节点。循环节点的文档可以参考:https://help.aliyun.com/document_detail/297383.html
如果小时任务0点开始每小时跑一次,那最后一个实例定时时间是23:00,产出当天最后一个分区数据,如果第二天的天人执行依赖前一天小时任务执行的话,天任务配置跨周期依赖小时任务即可,配置路径:
天任务的调度依赖配置--->选择上一周期---->依赖项选择其他节点,填写小时任务节点id即可。
希望对你有所帮助
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
MaxCompute(原ODPS)是一项面向分析的大数据计算服务,它以Serverless架构提供快速、全托管的在线数据仓库服务,消除传统数据平台在资源扩展性和弹性方面的限制,最小化用户运维投入,使您经济并高效的分析处理海量数据。