From f98a5ddbd0cb2ab579665a53a4667e4d98f1bc6e Mon Sep 17 00:00:00 2001
From: lilin <samz406@foxmail.com>
Date: Wed, 18 Dec 2019 11:10:19 +0800
Subject: [PATCH] extends  BaseTaskQueueTest get zkServer

---
 .../common/queue/TaskQueueZKImplTest.java              | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git a/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/queue/TaskQueueZKImplTest.java b/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/queue/TaskQueueZKImplTest.java
index 3db253daf0..b13f4f63c5 100644
--- a/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/queue/TaskQueueZKImplTest.java
+++ b/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/queue/TaskQueueZKImplTest.java
@@ -19,8 +19,6 @@ package org.apache.dolphinscheduler.common.queue;
 import org.apache.dolphinscheduler.common.Constants;
 import org.apache.dolphinscheduler.common.utils.IpUtils;
 import org.apache.dolphinscheduler.common.utils.OSUtils;
-
-import org.apache.dolphinscheduler.common.zk.ZKServer;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Ignore;
@@ -34,16 +32,14 @@ import static org.junit.Assert.*;
 /**
  * task queue test
  */
-public class TaskQueueZKImplTest  {
+public class TaskQueueZKImplTest extends BaseTaskQueueTest  {
+
 
 
-    private ITaskQueue tasksQueue = null;
 
     @Before
     public void before(){
 
-        ZKServer.start();
-        tasksQueue = TaskQueueFactory.getTaskQueueInstance();
         //clear all data
         tasksQueue.delete();
     }
@@ -52,10 +48,8 @@ public class TaskQueueZKImplTest  {
     public void after(){
         //clear all data
         tasksQueue.delete();
-        ZKServer.stop();
     }
 
-
     /**
      * test take out all the elements
      */