Flink任务处理的资源调整方法、装置、设备和存储介质

基本信息

申请号 CN202111400825.9 申请日 -
公开(公告)号 CN114116214A 公开(公告)日 2022-03-01
申请公布号 CN114116214A 申请公布日 2022-03-01
分类号 G06F9/50(2006.01)I 分类 计算;推算;计数;
发明人 范东;汪金忠;孙迁;方伍元;李成 申请(专利权)人 南京苏宁电子信息技术有限公司
代理机构 北京市万慧达律师事务所 代理人 刘艳丽
地址 210042江苏省南京市玄武区徐庄软件园苏宁大道1号
法律状态 -

摘要

摘要 本申请涉及一种Flink任务处理的资源调整方法、装置、设备和存储介质。所述方法包括:获取当前Flink任务的执行过程中各资源使用指标的实际使用量;根据各实际使用量以及各所述资源使用指标的指标参数,生成所述当前Flink任务的资源使用总评分;根据所述资源使用总评分以及资源使用总评分与调整策略的映射关系,得到所述当前Flink任务的调整策略;根据所述调整策略对所述当前Flink任务的资源分配进行调整。本申请通过设定多个资源使用指标,从多个维度对当前Flink任务的资源使用进行评分,并基于资源使用总评分与调整策略的映射关系精准定位到与当前Flink任务匹配的调整策略,使得调整策略的获取更加精准,基于该调整策略对资源进行调整,使得资源的调整更加准确。