diff --git a/src/main/java/org/opensearch/neuralsearch/query/SparseEncodingQueryBuilder.java b/src/main/java/org/opensearch/neuralsearch/query/SparseEncodingQueryBuilder.java index 430e6a1f6..07f581a9d 100644 --- a/src/main/java/org/opensearch/neuralsearch/query/SparseEncodingQueryBuilder.java +++ b/src/main/java/org/opensearch/neuralsearch/query/SparseEncodingQueryBuilder.java @@ -81,23 +81,23 @@ public static void initialize(MLCommonsClientAccessor mlClient) { public SparseEncodingQueryBuilder(StreamInput in) throws IOException { super(in); this.fieldName = in.readString(); - this.queryText = in.readOptionalString(); - this.modelId = in.readOptionalString(); + this.queryText = in.readString(); + this.modelId = in.readString(); } @Override protected void doWriteTo(StreamOutput out) throws IOException { out.writeString(fieldName); - out.writeOptionalString(queryText); - out.writeOptionalString(modelId); + out.writeString(queryText); + out.writeString(modelId); } @Override protected void doXContent(XContentBuilder xContentBuilder, Params params) throws IOException { xContentBuilder.startObject(NAME); xContentBuilder.startObject(fieldName); - if (null != queryText) xContentBuilder.field(QUERY_TEXT_FIELD.getPreferredName(), queryText); - if (null != modelId) xContentBuilder.field(MODEL_ID_FIELD.getPreferredName(), modelId); + xContentBuilder.field(QUERY_TEXT_FIELD.getPreferredName(), queryText); + xContentBuilder.field(MODEL_ID_FIELD.getPreferredName(), modelId); printBoostAndQueryName(xContentBuilder); xContentBuilder.endObject(); xContentBuilder.endObject();