diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java
index a2acf9bb29..b279c9224b 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java
@@ -162,7 +162,7 @@ public class WorkerServer extends AbstractServer {
                 scheduleAtFixedRate(heartBeatThread, 5, heartBeatInterval, TimeUnit.SECONDS);
 
         // kill process thread implement
-        Runnable killProcessThread = getKillProcessThread();
+        Runnable killProcessThread = getKillProcessThread(processDao);
 
         // submit kill process thread
         killExecutorService.execute(killProcessThread);
@@ -288,7 +288,7 @@ public class WorkerServer extends AbstractServer {
      *  kill process thread implement
      * @return
      */
-    private Runnable getKillProcessThread(){
+    private Runnable getKillProcessThread(ProcessDao processDao){
         Runnable killProcessThread  = new Runnable() {
             @Override
             public void run() {