Browse Source

update task queue format

pull/2/head
lenboo 5 years ago
parent
commit
570eeb030a
  1. 7
      escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java

7
escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java

@ -210,7 +210,12 @@ public class TaskQueueZkImpl extends AbstractZKClient implements ITaskQueue {
while(iterator.hasNext()){ while(iterator.hasNext()){
if(j++ < tasksNum){ if(j++ < tasksNum){
String task = iterator.next(); String task = iterator.next();
taskslist.add(task); String[] taskArray = task.split(Constants.UNDERLINE);
int processInstanceId = Integer.parseInt(taskArray[1]);
int taskId = Integer.parseInt(taskArray[3]);
String destTask = taskArray[0]+Constants.UNDERLINE + processInstanceId + Constants.UNDERLINE
+ taskArray[2] + Constants.UNDERLINE + taskId;
taskslist.add(destTask);
} }
} }
return taskslist; return taskslist;

Loading…
Cancel
Save