diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/bulk/BulkResponse.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/bulk/BulkResponse.java index 40505d5f32d..67c2ed2df31 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/bulk/BulkResponse.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/bulk/BulkResponse.java @@ -119,6 +119,7 @@ public class BulkResponse implements ActionResponse, Iterable for (int i = 0; i < responses.length; i++) { responses[i] = BulkItemResponse.readBulkItem(in); } + tookInMillis = in.readVLong(); } @Override public void writeTo(StreamOutput out) throws IOException { @@ -126,5 +127,6 @@ public class BulkResponse implements ActionResponse, Iterable for (BulkItemResponse response : responses) { response.writeTo(out); } + out.writeVLong(tookInMillis); } }