@@ -36,7 +36,7 @@ public class AbstractThrottledTaskRunnerTests extends ESTestCase {
36
36
public void setUp () throws Exception {
37
37
super .setUp ();
38
38
maxThreads = between (1 , 10 );
39
- executor = EsExecutors .newScaling ("test" , 1 , maxThreads , 0 , TimeUnit .MILLISECONDS , false , threadFactory , threadContext );
39
+ executor = EsExecutors .newScaling ("test" , maxThreads , maxThreads , 0 , TimeUnit .MILLISECONDS , false , threadFactory , threadContext );
40
40
}
41
41
42
42
@ Override
@@ -144,7 +144,7 @@ public void onResponse(Releasable releasable) {
144
144
145
145
public void testFailsTasksOnRejectionOrShutdown () throws Exception {
146
146
final var executor = randomBoolean ()
147
- ? EsExecutors .newScaling ("test" , 1 , maxThreads , 0 , TimeUnit .MILLISECONDS , true , threadFactory , threadContext )
147
+ ? EsExecutors .newScaling ("test" , maxThreads , maxThreads , 0 , TimeUnit .MILLISECONDS , true , threadFactory , threadContext )
148
148
: EsExecutors .newFixed ("test" , maxThreads , between (1 , 5 ), threadFactory , threadContext , false );
149
149
150
150
final var totalPermits = between (1 , maxThreads * 2 );
0 commit comments