Skip to content

Commit 9804e0e

Browse files
authored
Increase timeout for ensureGreen in testDownsampleIndexWithRollingRestart (#105277) (#105284)
1 parent b638556 commit 9804e0e

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

x-pack/plugin/downsample/src/internalClusterTest/java/org/elasticsearch/xpack/downsample/DownsampleClusterDisruptionIT.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public void run() {
109109
.getNodes()[0].getName();
110110
logger.info("Candidate node [" + candidateNode + "]");
111111
disruption.accept(candidateNode);
112-
ensureGreen(sourceIndex);
112+
ensureGreen(TimeValue.timeValueSeconds(60), sourceIndex);
113113
ensureStableCluster(cluster.numDataAndMasterNodes(), clientNode);
114114

115115
} catch (Exception e) {
@@ -208,7 +208,6 @@ public boolean validateClusterForming() {
208208
assertTargetIndex(cluster, sourceIndex, targetIndex, indexedDocs);
209209
}
210210

211-
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/100653")
212211
public void testDownsampleIndexWithRollingRestart() throws Exception {
213212
final InternalTestCluster cluster = internalCluster();
214213
final List<String> masterNodes = cluster.startMasterOnlyNodes(1);

x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/TransportDownsampleAction.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -955,11 +955,11 @@ public void onResponse(final AcknowledgedResponse response) {
955955
.indices()
956956
.forceMerge(request, ActionListener.wrap(mergeIndexResp -> actionListener.onResponse(AcknowledgedResponse.TRUE), t -> {
957957
/*
958-
* At this point downsampel index has been created
959-
* successfully even force merge fails.
960-
* So, we should not fail the downsample operation
958+
* At this point downsample index has been created
959+
* successfully even if force merge failed.
960+
* So, we should not fail the downsample operation.
961961
*/
962-
logger.error("Failed to force-merge " + "downsample index [" + downsampleIndexName + "]", t);
962+
logger.error("Failed to force-merge downsample index [" + downsampleIndexName + "]", t);
963963
actionListener.onResponse(AcknowledgedResponse.TRUE);
964964
}));
965965
}

0 commit comments

Comments
 (0)