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

摘要

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