1、运行环境
python38+ray 2.10
2. 问题描述
启动ray集群后,先后提交了两个job, 第一个job先运行,然后提交第二个job, 第二个job提交后,第一个job下的task就全部阻塞了,都是waiting for scheduler的状态,后提交的job下面的task反而开始执行。难道调度策略不是先到先运行吗,为什么后提交的任务反而先运行
Ray里面的任务调度并非是FIFO的,目前只要有pending的任务就会无差别去调度。
1、运行环境
python38+ray 2.10
2. 问题描述
启动ray集群后,先后提交了两个job, 第一个job先运行,然后提交第二个job, 第二个job提交后,第一个job下的task就全部阻塞了,都是waiting for scheduler的状态,后提交的job下面的task反而开始执行。难道调度策略不是先到先运行吗,为什么后提交的任务反而先运行
Ray里面的任务调度并非是FIFO的,目前只要有pending的任务就会无差别去调度。