一种基于深度强化学习的Spark Streaming参数优化方法

A Spark Streaming Parameter Optimization Method Based on Deep Reinforcement Learning

Spark Streaming作为主流的开源分布式流分析框架,性能优化是目前的研究热点之一。在Spark Streaming性能优化中,业务场景下的配置参数优化是其性能提升的重要因素。在Spark Streaming系统中,可配置的参数有200多个,对参数调优人员的经验要求较高,未经优化的参数配置会影响流作业执行性能。因此,针对Spark Streaming的参数配置优化问题,提出一种基于深度强化学习的Spark Streaming参数优化方法(DQN-SSPO),将Spark Streaming参数优化配置问题转化为深度强化学习模型训练中的最大回报获得问题,并提出权重状态空间转移方法来增加模型训练获得高反馈奖励的概率。在3种典型的流分析任务上进行实验,结果表明经参数优化后Spark Streaming上的流作业性能在总调度时间上平均缩减27.93%,在总处理时间上平均缩减42%。

Spark Streaming is the mainstream open source distributed stream analysis framework,and its performance optimization is one of the current research hotspots.In Spark Streaming performance optimization,configuration parameter optimization in business scenarios is an important factor in its performance improvement.In the Spark Streaming system,there are more than 200 configurable parameters,which requires high experience for parameter tuning personnel.Non optimized parameter configuration will affect the execution performance of streaming jobs.Therefore,in view of the parameter configuration optimization problem of Spark Streaming,a Spark Streaming parameter optimization method based on deep reinforcement learning(DQN-SSPO)is proposed,which converts the parameter optimization configuration problem of Spark Streaming into the problem of obtaining the maximum return in deep reinforcement learning model training,and a weighted state space transfer method is proposed to increase the probability of high feedback rewards for model training.Experiments on three typical streaming analysis tasks show that the performance of streaming jobs on Spark Streaming after parameter optimization is reduced by 27.93%in total scheduling time and 42%in total processing time.