Skip to content

Commit e6c1f6d

Browse files
authored
[8.x] [test] Fix RetrySearchIntegTests (elastic#122919) (elastic#123237)
Backports elastic#122919 to 8.x > Don't simultaneously restart multiple nodes in a cluster. It causes data races when multiple primaries are trying to mark the `[[.snapshot-blob-cache][0]]` shard as stale. ``` org.elasticsearch.cluster.action.shard.ShardStateAction$NoLongerPrimaryShardException: primary term [2] did not match current primary term [4] at org.elasticsearch.cluster.action.shard.ShardStateAction$ShardFailedClusterStateTaskExecutor.execute(ShardStateAction.java:355) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.cluster.service.MasterService.innerExecuteTasks(MasterService.java:1075) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.cluster.service.MasterService.executeTasks(MasterService.java:1038) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.cluster.service.MasterService.executeAndPublishBatch(MasterService.java:245) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.cluster.service.MasterService$BatchingTaskQueue$Processor.lambda$run$2(MasterService.java:1691) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.action.ActionListener.run(ActionListener.java:452) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.cluster.service.MasterService$BatchingTaskQueue$Processor.run(MasterService.java:1688) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.cluster.service.MasterService$5.lambda$doRun$0(MasterService.java:1283) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.action.ActionListener.run(ActionListener.java:452) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.cluster.service.MasterService$5.doRun(MasterService.java:1262) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:1044) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27) ~[elasticsearch-8.18.0-SNAPSHOT.jar:8.18.0-SNAPSHOT] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.lang.Thread.run(Thread.java:1575) ~[?:?] ``` Resolve elastic#118374 Resolve elastic#120442
1 parent ecdbba6 commit e6c1f6d

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

muted-tests.yml

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -355,9 +355,6 @@ tests:
355355
- class: org.elasticsearch.action.search.SearchQueryThenFetchAsyncActionTests
356356
method: testBottomFieldSort
357357
issue: https://github.com/elastic/elasticsearch/issues/118214
358-
- class: org.elasticsearch.xpack.searchablesnapshots.RetrySearchIntegTests
359-
method: testRetryPointInTime
360-
issue: https://github.com/elastic/elasticsearch/issues/120442
361358
- class: org.elasticsearch.xpack.inference.DefaultEndPointsIT
362359
method: testMultipleInferencesTriggeringDownloadAndDeploy
363360
issue: https://github.com/elastic/elasticsearch/issues/117208
@@ -429,9 +426,6 @@ tests:
429426
- class: org.elasticsearch.smoketest.DocsClientYamlTestSuiteIT
430427
method: test {yaml=reference/cat/allocation/cat-allocation-example}
431428
issue: https://github.com/elastic/elasticsearch/issues/121976
432-
- class: org.elasticsearch.xpack.searchablesnapshots.RetrySearchIntegTests
433-
method: testSearcherId
434-
issue: https://github.com/elastic/elasticsearch/issues/118374
435429
- class: org.elasticsearch.xpack.security.authc.ldap.GroupMappingIT
436430
issue: https://github.com/elastic/elasticsearch/issues/121291
437431
- class: org.elasticsearch.xpack.esql.qa.multi_node.EsqlSpecIT

x-pack/plugin/searchable-snapshots/src/internalClusterTest/java/org/elasticsearch/xpack/searchablesnapshots/RetrySearchIntegTests.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,7 @@ public void testSearcherId() throws Exception {
9090
for (String allocatedNode : allocatedNodes) {
9191
if (randomBoolean()) {
9292
internalCluster().restartNode(allocatedNode);
93+
ensureGreen(indexName);
9394
}
9495
}
9596
ensureGreen(indexName);
@@ -151,6 +152,7 @@ public void testRetryPointInTime() throws Exception {
151152
final Set<String> allocatedNodes = internalCluster().nodesInclude(indexName);
152153
for (String allocatedNode : allocatedNodes) {
153154
internalCluster().restartNode(allocatedNode);
155+
ensureGreen(indexName);
154156
}
155157
ensureGreen(indexName);
156158
assertNoFailuresAndResponse(

0 commit comments

Comments
 (0)