|
@@ -115,7 +115,8 @@ public class BulkRequestModifierTests extends ESTestCase {
|
|
|
List<BulkItemResponse> originalResponses = new ArrayList<>();
|
|
|
for (DocWriteRequest actionRequest : bulkRequest.requests()) {
|
|
|
IndexRequest indexRequest = (IndexRequest) actionRequest;
|
|
|
- IndexResponse indexResponse = new IndexResponse(new ShardId("index", "_na_", 0), indexRequest.type(), indexRequest.id(), 1, 1, true);
|
|
|
+ IndexResponse indexResponse = new IndexResponse(new ShardId("index", "_na_", 0), indexRequest.type(),
|
|
|
+ indexRequest.id(), 1, 1, true);
|
|
|
originalResponses.add(new BulkItemResponse(Integer.parseInt(indexRequest.id()), indexRequest.opType(), indexResponse));
|
|
|
}
|
|
|
bulkResponseListener.onResponse(new BulkResponse(originalResponses.toArray(new BulkItemResponse[originalResponses.size()]), 0));
|