honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[Transform] increase timeout in testStopWaitForCheckpoint (#63657) 

increase the overall timeout by increasing the wait time after every retry.

fixes #63365
This commit is contained in:
Hendrik Muhs 2020-10-15 08:45:38 +02:00
parent 822fea9889
commit 65ef399563
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
x-pack/plugin/transform/qa/multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TransformIntegTestCase.java
View File

@ -144,8 +144,9 @@ abstract class TransformIntegTestCase extends ESRestTestCase {
// workaround for https://github.com/elastic/elasticsearch/issues/62204 // workaround for https://github.com/elastic/elasticsearch/issues/62204
protected StartTransformResponse startTransformWithRetryOnConflict(String id, RequestOptions options) throws Exception { protected StartTransformResponse startTransformWithRetryOnConflict(String id, RequestOptions options) throws Exception {
final int totalRetries = 10;
ElasticsearchStatusException lastConflict = null; ElasticsearchStatusException lastConflict = null;
for (int retries = 10; retries > 0; --retries) { for (int retries = totalRetries; retries > 0; --retries) {
try (RestHighLevelClient restClient = new TestRestHighLevelClient()) { try (RestHighLevelClient restClient = new TestRestHighLevelClient()) {
return restClient.transform().startTransform(new StartTransformRequest(id), options); return restClient.transform().startTransform(new StartTransformRequest(id), options);
} catch (ElasticsearchStatusException e) { } catch (ElasticsearchStatusException e) {
@ -162,7 +163,7 @@ abstract class TransformIntegTestCase extends ESRestTestCase {
} }
lastConflict = e; lastConflict = e;
Thread.sleep(5); Thread.sleep(5 * (1 + totalRetries - retries));
} }
} }
throw lastConflict; throw lastConflict;