java - 为什么我的 Elasticsearch 集成测试有时只能工作

Question

我有以下集成测试:

public class TestElasticIT extends ESIntegTestCase {
  private static final String esIndex = "test";
  private static final String esEntityType = "entity";
  private static final String esDetailType = "details";
  private Client client = null;

  @Before
  public void beforeTests() throws Exception {
     XContentBuilder xContentBuilder = XContentFactory.jsonBuilder().startObject().startObject(esEntityType).endObject().endObject();
     XContentBuilder xContentBuilder2 = XContentFactory.jsonBuilder().startObject().startObject(esDetailType).startObject("_parent").field("type", esEntityType).endObject().endObject().endObject();

     client = ESIntegTestCase.client();
     createIndex(esIndex);

     client.admin().indices().preparePutMapping(esIndex).setType(esDetailType).setSource(xContentBuilder2).get();
     client.admin().indices().preparePutMapping(esIndex).setType(esEntityType).setSource(xContentBuilder).get();
  }

  @Test
  public void testCreateAndRead() throws Exception {
     ensureGreen(esIndex);

     IndexResponse entityResponse = client.prepareIndex(esIndex, esEntityType).setSource(testJson).get(); //This could be any key/value json
     IndexResponse detailResponse = client.prepareIndex(esIndex, esDetailType).setSource(testJsonDetail).setParent(entityResponse.getId()).get();

     //I want to see both parent and child here
     System.out.println(client.prepareSearch().execute().actionGet());
  }  
}

我遇到的问题是 client.prepareSearch().execute().actionGet() 只会偶尔返回我的 testJson 。有时它会起作用，但大多数时候它什么也不返回。我怎样才能让我的集成测试每次都通过？

编辑:有时有效或无效的查询:

client.prepareGet().setIndex(esIndex).setId(detailResponse.getId()).get();
client.prepareGet().setIndex(esIndex).setType(esDetailType).setRouting(esEntityType).setId(detailResponse.getId()).get();

Answer 1

这是一个竞争条件，可能是因为您在创建索引后没有调用refresh()，而是在运行搜索请求之前依赖 ES 进行更新。

由于您的类扩展了 ESIntegTestCase，您应该能够执行类似的操作

this.refresh(esIndex);

有关测试 API 中此方法的更多信息，请参阅以下链接: https://www.elastic.co/guide/en/elasticsearch/reference/current/integration-tests.html https://github.com/elastic/elasticsearch/blob/master/test/framework/src/main/java/org/elasticsearch/test/ESIntegTestCase.java#L1186

这也可以在主(非测试)Java API 中使用，如下所示:

client.admin().indices().prepareRefresh(esIndex).get();

有关 Java API 可用性的更多信息，请参阅此处: https://static.javadoc.io/org.elasticsearch/elasticsearch/2.3.0/org/elasticsearch/client/IndicesAdminClient.html#refresh(org.elasticsearch.action.admin.indices.refresh.RefreshRequest)

编辑:

我上面提供的第一个片段仅适用于 Elasticsearch 5.0 Alpha。在当前版本中，刷新方法不带参数: https://github.com/elastic/elasticsearch/blob/v2.4.0/core/src/test/java/org/elasticsearch/test/ESIntegTestCase.java