一种网格水文模型并行计算的负载均衡任务调度方法

本发明公开一种网格水文模型并行计算的负载均衡任务调度方法。该方法包括：(1)模型基于构件特点分析：对网格新安江模型的四个子模型处理流程进行分析，确定模型输入文件、相关参数及模型之间的调用关系和模型输出结果；将模型从三种类型的构件——独立计算构件、时间顺序依赖构件、空间逻辑依赖构件，并分析其在分布式并行计算框架下的处理方式。(2)Flink集群搭建和并行算法设计：依据前述分析，将任务划分为多个子任务，分配到不同计算节点，利用Flink的并行计算能力处理这些子任务。(3)提出了基于资源反馈的负载均衡任务调度算法：针对分布式系统中出现的负载不均的情况，通过实时资源监控，把负载过重的机器中处于等待状态的任务分配给负载较轻的机器，来实现集群的负载均衡。(4)结果整合：对各模型的计算结果进行整合，输出最终的水文模拟结果。本发明提供一种网格水文模型并行计算的负载均衡任务调度方法，通过Flink并行计算框架对网格新安江模型的子任务进行分布式处理，并通过负载均衡，以提高水文模拟计算效率。