We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6e92a76 commit 564cbeeCopy full SHA for 564cbee
server/src/main/java/org/opensearch/action/bulk/BulkItemRequest.java
@@ -139,7 +139,9 @@ public void writeTo(StreamOutput out) throws IOException {
139
public void writeThin(StreamOutput out) throws IOException {
140
out.writeVInt(id);
141
DocWriteRequest.writeDocumentRequestThin(out, request);
142
- out.writeOptionalWriteable(primaryResponse == null ? null : primaryResponse::writeThin);
+
143
+ BulkItemResponse primaryResponse = this.primaryResponse; // Read volatile once
144
+ out.writeOptionalWriteable((o, resp) -> resp.writeThin(o), primaryResponse);
145
}
146
147
@Override
0 commit comments