|
|
@@ -9,7 +9,6 @@
|
|
|
package org.elasticsearch.ingest.geoip;
|
|
|
|
|
|
import org.apache.lucene.util.Constants;
|
|
|
-import org.apache.lucene.util.LuceneTestCase;
|
|
|
import org.elasticsearch.action.index.IndexRequest;
|
|
|
import org.elasticsearch.action.index.IndexResponse;
|
|
|
import org.elasticsearch.action.ingest.PutPipelineRequest;
|
|
|
@@ -30,7 +29,6 @@ import static org.elasticsearch.test.NodeRoles.nonIngestNode;
|
|
|
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked;
|
|
|
import static org.hamcrest.Matchers.equalTo;
|
|
|
|
|
|
-@LuceneTestCase.AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/71251")
|
|
|
public class GeoIpProcessorNonIngestNodeIT extends AbstractGeoIpIT {
|
|
|
|
|
|
@Override
|
|
|
@@ -103,7 +101,7 @@ public class GeoIpProcessorNonIngestNodeIT extends AbstractGeoIpIT {
|
|
|
final IndexRequest indexRequest = new IndexRequest("index");
|
|
|
indexRequest.setPipeline("geoip");
|
|
|
indexRequest.source(Collections.singletonMap("ip", "1.1.1.1"));
|
|
|
- final IndexResponse indexResponse = client().index(indexRequest).actionGet();
|
|
|
+ final IndexResponse indexResponse = client(ingestNode).index(indexRequest).actionGet();
|
|
|
assertThat(indexResponse.status(), equalTo(RestStatus.CREATED));
|
|
|
// now the geo-IP database should be loaded on the ingest node
|
|
|
assertDatabaseLoadStatus(ingestNode, true);
|