diff --git a/plugins/transport/thrift/src/main/java/org/elasticsearch/thrift/ThriftRestRequest.java b/plugins/transport/thrift/src/main/java/org/elasticsearch/thrift/ThriftRestRequest.java index ff0067bbff7..4724a1a93b3 100644 --- a/plugins/transport/thrift/src/main/java/org/elasticsearch/thrift/ThriftRestRequest.java +++ b/plugins/transport/thrift/src/main/java/org/elasticsearch/thrift/ThriftRestRequest.java @@ -96,7 +96,7 @@ public class ThriftRestRequest extends AbstractRestRequest implements org.elasti if (!request.isSetBody()) { return 0; } - return request.bufferForBody().arrayOffset(); + return request.bufferForBody().arrayOffset() + request.bufferForBody().position(); } @Override public int contentLength() {