并行度的调整方法、装置、设备、存储介质及程序产品

本公开涉及数据流处理技术领域，公开了并行度的调整方法、装置、设备、存储介质及程序产品。其中，该方法包括：获取目标流处理任务的历史执行数据以及目标流处理任务对应的各个数据流算子；从历史执行数据中分离数据流算子对应的算子并行度和算子性能特征，确定算子并行度和算子性能特征之间的关联关系；若算子性能特征表征数据流算子在算子并行度下存在算子瓶颈，则利用关联关系对算子并行度进行调整，得到数据流算子的目标并行度。通过实施本公开技术方案，能够充分利用历史执行数据对目标流处理任务的算子并行度进行有效调优，保证调优后的目标并行度能够有效缓解算子瓶颈压力，提升了并行度的调优效率和调优准确性。