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 <[email protected]>
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);*/
}