Commit 81a24a20 authored by Shikhar Bhushan's avatar Shikhar Bhushan
Browse files

Tests bug: Narrow search by index as expected

parent 56977521

src/test/java/io/confluent/connect/elasticsearch/ElasticsearchSinkTestBase.java

+1 −1
Original line number Diff line number Diff line
@@ -114,7 +114,7 @@ public class ElasticsearchSinkTestBase extends ESIntegTestCase { 
  }



  protected void verifySearchResults(Collection<SinkRecord> records, String index, boolean ignoreKey, boolean ignoreSchema) throws IOException {

    final SearchResult result = client.execute(new Search.Builder("").build());

    final SearchResult result = client.execute(new Search.Builder("").addIndex(index).build());



    final JsonArray rawHits = result.getJsonObject().getAsJsonObject("hits").getAsJsonArray("hits");