提交 4cd1e7e5 编写于 作者: L lgcareer

[Fix-4222][Master]Add the priority queue to ensure that tasks are submitted according to priority.

上级 bd7db688
......@@ -1004,7 +1004,8 @@ public class MasterExecThread implements Runnable {
private void submitStandByTask(){
try {
for (int i=0;i<readyToSubmitTaskQueue.size();i++) {
int length = readyToSubmitTaskQueue.size();
for (int i=0;i<length;i++) {
TaskInstance task = readyToSubmitTaskQueue.peek();
DependResult dependResult = getDependResultForTask(task);
if(DependResult.SUCCESS == dependResult){
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册