You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by li...@apache.org on 2020/05/30 03:39:58 UTC
[incubator-dolphinscheduler] 01/01: fix
TaskPriorityQueueConsumerTest.testSqoopTask WrongTypeOfReturnValue
This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a commit to branch dailidong-patch-1
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
commit ad93ba8b5974d5eba5403e78dc8e919a836af17e
Author: dailidong <da...@gmail.com>
AuthorDate: Sat May 30 11:39:49 2020 +0800
fix TaskPriorityQueueConsumerTest.testSqoopTask WrongTypeOfReturnValue
fix TaskPriorityQueueConsumerTest.testSqoopTask:236 WrongTypeOfReturnValue
---
.../server/master/consumer/TaskPriorityQueueConsumerTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 b6f118a..b247dc4 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
@@ -22,6 +22,7 @@ import org.apache.dolphinscheduler.common.enums.DbType;
import org.apache.dolphinscheduler.common.enums.ExecutionStatus;
import org.apache.dolphinscheduler.common.enums.Priority;
import org.apache.dolphinscheduler.dao.entity.*;
+import org.apache.dolphinscheduler.server.master.config.MasterConfig;
import org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher;
import org.apache.dolphinscheduler.server.master.dispatch.executor.NettyExecutorManager;
import org.apache.dolphinscheduler.server.registry.DependencyConfig;
@@ -48,7 +49,7 @@ import java.util.Date;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes={DependencyConfig.class, SpringApplicationContext.class, SpringZKServer.class,
NettyExecutorManager.class, ExecutorDispatcher.class, ZookeeperRegistryCenter.class, TaskPriorityQueueConsumer.class,
- ZookeeperNodeManager.class, ZookeeperCachedOperator.class, ZookeeperConfig.class})
+ ZookeeperNodeManager.class, ZookeeperCachedOperator.class, ZookeeperConfig.class, MasterConfig.class})
public class TaskPriorityQueueConsumerTest {
@@ -234,7 +235,6 @@ public class TaskPriorityQueueConsumerTest {
dataSource.setUpdateTime(new Date());
Mockito.when(processService.findDataSourceById(1)).thenReturn(dataSource);
-
Thread.sleep(10000);
}