From 67f82d71a8dc9a1d02aa311392af4ca512f17a79 Mon Sep 17 00:00:00 2001
From: lenboo <denny1011@163.com>
Date: Fri, 5 Jul 2019 15:26:03 +0800
Subject: [PATCH] update worker get task from queue

---
 .../cn/escheduler/server/worker/runner/FetchTaskThread.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
index a960570ea5..2d88fdb843 100644
--- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
+++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
@@ -153,7 +153,7 @@ public class FetchTaskThread implements Runnable{
                                 }
 
                                 String[] taskStringArray = taskQueueStr.split(Constants.UNDERLINE);
-                                String taskInstIdStr = taskStringArray[taskStringArray.length - 1];
+                                String taskInstIdStr = taskStringArray[3];
                                 Date now = new Date();
                                 Integer taskId = Integer.parseInt(taskInstIdStr);