File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
client/rest-high-level/src/test/java/org/elasticsearch/client Expand file tree Collapse file tree 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) {
292292 assertThat (response .getTasks ().get (0 ).getStatus (), instanceOf (RawTaskStatus .class ));
293293 assertEquals (Float .toString (requestsPerSecond ),
294294 ((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 ) );
296296
297297 // any rethrottling after the update-by-query is done performed with the same taskId should result in a failure
298298 response = execute (new RethrottleRequest (taskIdToRethrottle , requestsPerSecond ),
@@ -423,7 +423,7 @@ public void onFailure(Exception e) {
423423 assertThat (response .getTasks ().get (0 ).getStatus (), instanceOf (RawTaskStatus .class ));
424424 assertEquals (Float .toString (requestsPerSecond ),
425425 ((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 ) );
427427
428428 // any rethrottling after the delete-by-query is done performed with the same taskId should result in a failure
429429 response = execute (new RethrottleRequest (taskIdToRethrottle , requestsPerSecond ),
You can’t perform that action at this time.
0 commit comments