Skip to content

Commit 4db5fc5

Browse files
committed
Avoid running simulate pipeline request on coordinating only node.
Relates to #79074
1 parent 1bd84d8 commit 4db5fc5

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import org.elasticsearch.action.ingest.SimulatePipelineRequest;
1717
import org.elasticsearch.action.ingest.SimulatePipelineResponse;
1818
import org.elasticsearch.action.search.SearchResponse;
19+
import org.elasticsearch.client.Client;
1920
import org.elasticsearch.cluster.node.DiscoveryNode;
2021
import org.elasticsearch.common.bytes.BytesReference;
2122
import org.elasticsearch.common.settings.Settings;
@@ -428,7 +429,10 @@ private SimulateDocumentBaseResult simulatePipeline() throws IOException {
428429
}
429430
SimulatePipelineRequest simulateRequest = new SimulatePipelineRequest(bytes, XContentType.JSON);
430431
simulateRequest.setId("_id");
431-
SimulatePipelineResponse simulateResponse = client().admin().cluster().simulatePipeline(simulateRequest).actionGet();
432+
// Avoid executing on a coordinating only node, because databases are not available there and geoip processor won't do any lookups.
433+
// (some test seeds repeatedly hit such nodes causing failures)
434+
Client client = dataNodeClient();
435+
SimulatePipelineResponse simulateResponse = client.admin().cluster().simulatePipeline(simulateRequest).actionGet();
432436
assertThat(simulateResponse.getPipelineId(), equalTo("_id"));
433437
assertThat(simulateResponse.getResults().size(), equalTo(1));
434438
return (SimulateDocumentBaseResult) simulateResponse.getResults().get(0);

0 commit comments

Comments
 (0)