|
@@ -201,7 +201,7 @@ public class AdaptiveAllocationsScalerServiceTests extends ESTestCase {
|
|
|
return Void.TYPE;
|
|
|
}).when(client).execute(eq(GetDeploymentStatsAction.INSTANCE), eq(new GetDeploymentStatsAction.Request("test-deployment")), any());
|
|
|
|
|
|
- safeSleep(1200);
|
|
|
+ safeSleep(1500);
|
|
|
|
|
|
verify(client, times(1)).threadPool();
|
|
|
verify(client, times(1)).execute(eq(GetDeploymentStatsAction.INSTANCE), any(), any());
|
|
@@ -295,7 +295,7 @@ public class AdaptiveAllocationsScalerServiceTests extends ESTestCase {
|
|
|
return Void.TYPE;
|
|
|
}).when(client).execute(eq(GetDeploymentStatsAction.INSTANCE), eq(new GetDeploymentStatsAction.Request("test-deployment")), any());
|
|
|
|
|
|
- safeSleep(1200);
|
|
|
+ safeSleep(1500);
|
|
|
|
|
|
verify(client, times(1)).threadPool();
|
|
|
verify(client, times(1)).execute(eq(GetDeploymentStatsAction.INSTANCE), any(), any());
|
|
@@ -418,7 +418,7 @@ public class AdaptiveAllocationsScalerServiceTests extends ESTestCase {
|
|
|
return Void.TYPE;
|
|
|
}).when(client).execute(eq(GetDeploymentStatsAction.INSTANCE), eq(new GetDeploymentStatsAction.Request("test-deployment")), any());
|
|
|
|
|
|
- safeSleep(1200);
|
|
|
+ safeSleep(1500);
|
|
|
|
|
|
verify(client, times(1)).threadPool();
|
|
|
verify(client, times(1)).execute(eq(GetDeploymentStatsAction.INSTANCE), any(), any());
|
|
@@ -572,5 +572,4 @@ public class AdaptiveAllocationsScalerServiceTests extends ESTestCase {
|
|
|
100L
|
|
|
);
|
|
|
}
|
|
|
-
|
|
|
}
|