Skip to content

Commit 8d47828

Browse files
committed
Use length() instead of ramBytesUsed()
1 parent dbc8d74 commit 8d47828

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/action/filter/ShardBulkInferenceActionFilter.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -631,7 +631,7 @@ private boolean incrementIndexingPressure(IndexRequestWithIndexingPressure index
631631
if (indexRequest.isIndexingPressureIncremented() == false) {
632632
try {
633633
// Track operation count as one operation per document source update
634-
coordinatingIndexingPressure.increment(1, indexRequest.getIndexRequest().source().ramBytesUsed());
634+
coordinatingIndexingPressure.increment(1, indexRequest.getIndexRequest().source().length());
635635
indexRequest.setIndexingPressureIncremented();
636636
} catch (EsRejectedExecutionException e) {
637637
addInferenceResponseFailure(
@@ -737,13 +737,13 @@ private void applyInferenceResponses(BulkItemRequest item, FieldInferenceRespons
737737
indexRequest.source(builder);
738738
}
739739
}
740-
long modifiedSourceSize = indexRequest.source().ramBytesUsed();
740+
long modifiedSourceSize = indexRequest.source().length();
741741

742742
// Add the indexing pressure from the source modifications.
743743
// Don't increment operation count because we count one source update as one operation, and we already accounted for those
744744
// in addFieldInferenceRequests.
745745
try {
746-
coordinatingIndexingPressure.increment(0, modifiedSourceSize - originalSource.ramBytesUsed());
746+
coordinatingIndexingPressure.increment(0, modifiedSourceSize - originalSource.length());
747747
} catch (EsRejectedExecutionException e) {
748748
indexRequest.source(originalSource, indexRequest.getContentType());
749749
item.abort(

0 commit comments

Comments
 (0)