This is an automated email from the ASF dual-hosted git repository.

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 3a0d4da  [Test][server] Fix Test ContextConfiguration error. (#3304)
3a0d4da is described below

commit 3a0d4da27e6f981ecba7d061bad4644079ae122d
Author: CalvinKirs <[email protected]>
AuthorDate: Thu Jul 30 13:28:27 2020 +0800

    [Test][server] Fix Test ContextConfiguration error. (#3304)
    
    * [FIX_BUG]fix test error
    
    * small change
    
    * add test
    
    * reformat
    
    * fix test no qualifying bean
---
 .../server/master/consumer/TaskPriorityQueueConsumerTest.java       | 3 ++-
 .../dolphinscheduler/server/registry/ZookeeperNodeManagerTest.java  | 3 ++-
 .../server/worker/processor/TaskCallbackServiceTest.java            | 4 +++-
 pom.xml                                                             | 6 +++---
 4 files changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/consumer/TaskPriorityQueueConsumerTest.java
 
b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/consumer/TaskPriorityQueueConsumerTest.java
index dce80ab..997c129 100644
--- 
a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/consumer/TaskPriorityQueueConsumerTest.java
+++ 
b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/consumer/TaskPriorityQueueConsumerTest.java
@@ -39,6 +39,7 @@ import org.apache.dolphinscheduler.server.zk.SpringZKServer;
 import org.apache.dolphinscheduler.service.bean.SpringApplicationContext;
 import org.apache.dolphinscheduler.service.process.ProcessService;
 import org.apache.dolphinscheduler.service.queue.TaskPriorityQueue;
+import org.apache.dolphinscheduler.service.zk.CuratorZookeeperClient;
 import org.apache.dolphinscheduler.service.zk.ZookeeperCachedOperator;
 import org.apache.dolphinscheduler.service.zk.ZookeeperConfig;
 import org.junit.After;
@@ -52,7 +53,7 @@ import 
org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 
 @RunWith(SpringJUnit4ClassRunner.class)
-@ContextConfiguration(classes={DependencyConfig.class, 
SpringApplicationContext.class, SpringZKServer.class,
+@ContextConfiguration(classes={DependencyConfig.class, 
SpringApplicationContext.class, SpringZKServer.class, 
CuratorZookeeperClient.class,
         NettyExecutorManager.class, ExecutorDispatcher.class, 
ZookeeperRegistryCenter.class, TaskPriorityQueueConsumer.class,
         ZookeeperNodeManager.class, ZookeeperCachedOperator.class, 
ZookeeperConfig.class, MasterConfig.class})
 public class TaskPriorityQueueConsumerTest {
diff --git 
a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/registry/ZookeeperNodeManagerTest.java
 
b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/registry/ZookeeperNodeManagerTest.java
index 4ec225b..f6eb861 100644
--- 
a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/registry/ZookeeperNodeManagerTest.java
+++ 
b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/registry/ZookeeperNodeManagerTest.java
@@ -27,6 +27,7 @@ import 
org.apache.dolphinscheduler.server.master.registry.MasterRegistry;
 import org.apache.dolphinscheduler.server.worker.config.WorkerConfig;
 import org.apache.dolphinscheduler.server.worker.registry.WorkerRegistry;
 import org.apache.dolphinscheduler.server.zk.SpringZKServer;
+import org.apache.dolphinscheduler.service.zk.CuratorZookeeperClient;
 import org.apache.dolphinscheduler.service.zk.ZookeeperCachedOperator;
 import org.apache.dolphinscheduler.service.zk.ZookeeperConfig;
 import org.junit.Assert;
@@ -42,7 +43,7 @@ import 
org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes={DependencyConfig.class, SpringZKServer.class, 
MasterRegistry.class,WorkerRegistry.class,
         ZookeeperRegistryCenter.class, MasterConfig.class, WorkerConfig.class,
-        ZookeeperCachedOperator.class, ZookeeperConfig.class, 
ZookeeperNodeManager.class})
+        ZookeeperCachedOperator.class, ZookeeperConfig.class, 
ZookeeperNodeManager.class, CuratorZookeeperClient.class})
 public class ZookeeperNodeManagerTest {
 
     @Autowired
diff --git 
a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackServiceTest.java
 
b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackServiceTest.java
index dee8cd9..8d58459 100644
--- 
a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackServiceTest.java
+++ 
b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackServiceTest.java
@@ -41,6 +41,7 @@ import 
org.apache.dolphinscheduler.server.worker.config.WorkerConfig;
 import org.apache.dolphinscheduler.server.worker.registry.WorkerRegistry;
 import org.apache.dolphinscheduler.server.zk.SpringZKServer;
 import org.apache.dolphinscheduler.service.bean.SpringApplicationContext;
+import org.apache.dolphinscheduler.service.zk.CuratorZookeeperClient;
 import org.apache.dolphinscheduler.service.zk.ZookeeperCachedOperator;
 import org.apache.dolphinscheduler.service.zk.ZookeeperConfig;
 import org.junit.Assert;
@@ -73,7 +74,8 @@ import io.netty.channel.Channel;
         TaskResponseService.class,
         TaskAckProcessor.class,
         TaskResponseProcessor.class,
-        TaskExecuteProcessor.class})
+        TaskExecuteProcessor.class,
+        CuratorZookeeperClient.class})
 public class TaskCallbackServiceTest {
 
     @Autowired
diff --git a/pom.xml b/pom.xml
index 71f8de9..196e95a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -798,7 +798,7 @@
                         
<!--<include>**/server/log/TaskLogDiscriminatorTest.java</include>-->
                         <include>**/server/log/TaskLogFilterTest.java</include>
                         
<include>**/server/log/WorkerLogFilterTest.java</include>
-                        
<!--<include>**/server/master/consumer/TaskPriorityQueueConsumerTest.java</include>-->
+                        
<include>**/server/master/consumer/TaskPriorityQueueConsumerTest.java</include>
                         
<include>**/server/master/runner/MasterTaskExecThreadTest.java</include>
                         
<!--<include>**/server/master/dispatch/executor/NettyExecutorManagerTest.java</include>-->
                         
<include>**/server/master/dispatch/host/assign/LowerWeightRoundRobinTest.java</include>
@@ -811,14 +811,14 @@
                         
<!--<include>**/server/master/ConditionsTaskTest.java</include>-->
                         
<include>**/server/master/MasterExecThreadTest.java</include>
                         <include>**/server/master/ParamsTest.java</include>
-                        
<!--<include>**/server/register/ZookeeperNodeManagerTest.java</include>-->
+                        
<include>**/server/register/ZookeeperNodeManagerTest.java</include>
                         <include>**/server/utils/DataxUtilsTest.java</include>
                         
<include>**/server/utils/ExecutionContextTestUtils.java</include>
                         
<!--<include>**/server/utils/FlinkArgsUtilsTest.java</include>-->
                         <include>**/server/utils/ParamUtilsTest.java</include>
                         
<include>**/server/utils/ProcessUtilsTest.java</include>
                         
<include>**/server/utils/SparkArgsUtilsTest.java</include>
-                        
<!--<include>**/server/worker/processor/TaskCallbackServiceTest.java</include>-->
+                        
<include>**/server/worker/processor/TaskCallbackServiceTest.java</include>
                         
<include>**/server/worker/registry/WorkerRegistryTest.java</include>
                         
<include>**/server/worker/shell/ShellCommandExecutorTest.java</include>
                         
<include>**/server/worker/sql/SqlExecutorTest.java</include>

Reply via email to