You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by zi...@apache.org on 2022/04/15 03:32:28 UTC
[dolphinscheduler] branch dev updated: [Improvement][Master] Fix typo for MasterTaskExecThreadTest (#9513)
This is an automated email from the ASF dual-hosted git repository.
zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 3815a86a3b [Improvement][Master] Fix typo for MasterTaskExecThreadTest (#9513)
3815a86a3b is described below
commit 3815a86a3bec7d5a39a80f565e4560cab7212dba
Author: Paul Zhang <xz...@126.com>
AuthorDate: Fri Apr 15 11:32:22 2022 +0800
[Improvement][Master] Fix typo for MasterTaskExecThreadTest (#9513)
---
.../server/master/runner/MasterTaskExecThreadTest.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThreadTest.java b/dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThreadTest.java
index 35128388e3..fb258cb267 100644
--- a/dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThreadTest.java
+++ b/dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThreadTest.java
@@ -74,21 +74,21 @@ public class MasterTaskExecThreadTest {
@Test
public void testExistsValidWorkerGroup2() {
- Set<String> workerGorups = new HashSet<>();
- workerGorups.add("test1");
- workerGorups.add("test2");
+ Set<String> workerGroups = new HashSet<>();
+ workerGroups.add("test1");
+ workerGroups.add("test2");
- /* Mockito.when(registryCenter.getWorkerGroupDirectly()).thenReturn(workerGorups);
+ /* Mockito.when(registryCenter.getWorkerGroupDirectly()).thenReturn(workerGroups);
boolean b = masterTaskExecThread.existsValidWorkerGroup("default");
Assert.assertFalse(b);*/
}
@Test
public void testExistsValidWorkerGroup3() {
- Set<String> workerGorups = new HashSet<>();
- workerGorups.add("test1");
- /* Mockito.when(registryCenter.getWorkerGroupDirectly()).thenReturn(workerGorups);
- Mockito.when(registryCenter.getWorkerGroupNodesDirectly("test1")).thenReturn(workerGorups);
+ Set<String> workerGroups = new HashSet<>();
+ workerGroups.add("test1");
+ /* Mockito.when(registryCenter.getWorkerGroupDirectly()).thenReturn(workerGroups);
+ Mockito.when(registryCenter.getWorkerGroupNodesDirectly("test1")).thenReturn(workerGroups);
boolean b = masterTaskExecThread.existsValidWorkerGroup("test1");
Assert.assertTrue(b);*/
}