Skip to content

Commit

Permalink
fixed typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Blazer-007 committed Feb 7, 2025
1 parent 90b7e6c commit 4c7b019
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -70,11 +70,11 @@ public void testWhenScalingDirectivesIsNulOrEmpty() throws IOException, Interrup
@Test
public void testWithDummyScalingDirectiveSource() throws IOException, InterruptedException {
// DummyScalingDirectiveSource returns 2 scaling directives in first 5 invocations and after that it returns empty list
// so the total number of invocations after three invocations should always be 5
// so the total number of invocations after five invocations should always be 5
TestDynamicScalingYarnServiceManager testDynamicScalingYarnServiceManager = new TestDynamicScalingYarnServiceManager(
mockGobblinTemporalApplicationMaster, new DummyScalingDirectiveSource());
testDynamicScalingYarnServiceManager.startUp();
Thread.sleep(7000); // 5 seconds sleep so that GetScalingDirectivesRunnable.run() is called for 7 times
Thread.sleep(7000); // 7 seconds sleep so that GetScalingDirectivesRunnable.run() is called for 7 times
testDynamicScalingYarnServiceManager.shutDown();
Mockito.verify(mockDynamicScalingYarnService, Mockito.times(5)).reviseWorkforcePlanAndRequestNewContainers(Mockito.anyList());
}
Expand Down

0 comments on commit 4c7b019

Please sign in to comment.