From 570eeb030a48b3258f015c20824a8ef5ab4ef596 Mon Sep 17 00:00:00 2001
From: lenboo <denny1011@163.com>
Date: Thu, 4 Jul 2019 20:30:39 +0800
Subject: [PATCH] update task queue format

---
 .../java/cn/escheduler/common/queue/TaskQueueZkImpl.java   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java b/escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java
index 88915b97cc..2c2e3ef4d9 100644
--- a/escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java
+++ b/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()){
             if(j++ < tasksNum){
                 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;