File tree 1 file changed +2
-2
lines changed
client/rest-high-level/src/test/java/org/elasticsearch/client 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -292,7 +292,7 @@ public void onFailure(Exception e) {
292
292
assertThat (response .getTasks ().get (0 ).getStatus (), instanceOf (RawTaskStatus .class ));
293
293
assertEquals (Float .toString (requestsPerSecond ),
294
294
((RawTaskStatus ) response .getTasks ().get (0 ).getStatus ()).toMap ().get ("requests_per_second" ).toString ());
295
- taskFinished .await (2 , TimeUnit .SECONDS );
295
+ assertTrue ( taskFinished .await (10 , TimeUnit .SECONDS ) );
296
296
297
297
// any rethrottling after the update-by-query is done performed with the same taskId should result in a failure
298
298
response = execute (new RethrottleRequest (taskIdToRethrottle , requestsPerSecond ),
@@ -423,7 +423,7 @@ public void onFailure(Exception e) {
423
423
assertThat (response .getTasks ().get (0 ).getStatus (), instanceOf (RawTaskStatus .class ));
424
424
assertEquals (Float .toString (requestsPerSecond ),
425
425
((RawTaskStatus ) response .getTasks ().get (0 ).getStatus ()).toMap ().get ("requests_per_second" ).toString ());
426
- taskFinished .await (2 , TimeUnit .SECONDS );
426
+ assertTrue ( taskFinished .await (10 , TimeUnit .SECONDS ) );
427
427
428
428
// any rethrottling after the delete-by-query is done performed with the same taskId should result in a failure
429
429
response = execute (new RethrottleRequest (taskIdToRethrottle , requestsPerSecond ),
You can’t perform that action at this time.
0 commit comments