Skip to content

Commit 7fe9931

Browse files
authored
Add transport version for 8.19 rerank failure field (#128251)
1 parent 888ce0b commit 7fe9931

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

server/src/main/java/org/elasticsearch/TransportVersions.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -178,6 +178,7 @@ static TransportVersion def(int id) {
178178
public static final TransportVersion ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED_8_19 = def(8_841_0_31);
179179
public static final TransportVersion V_8_19_FIELD_CAPS_ADD_CLUSTER_ALIAS = def(8_841_0_32);
180180
public static final TransportVersion ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME_8_19 = def(8_841_0_34);
181+
public static final TransportVersion RERANKER_FAILURES_ALLOWED_8_19 = def(8_841_0_35);
181182
public static final TransportVersion V_9_0_0 = def(9_000_0_09);
182183
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_1 = def(9_000_0_10);
183184
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_2 = def(9_000_0_11);

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/rank/textsimilarity/TextSimilarityRankBuilder.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,8 @@ public TextSimilarityRankBuilder(StreamInput in) throws IOException {
7878
this.inferenceText = in.readString();
7979
this.field = in.readString();
8080
this.minScore = in.readOptionalFloat();
81-
if (in.getTransportVersion().onOrAfter(TransportVersions.RERANKER_FAILURES_ALLOWED)) {
81+
if (in.getTransportVersion().isPatchFrom(TransportVersions.RERANKER_FAILURES_ALLOWED_8_19)
82+
|| in.getTransportVersion().onOrAfter(TransportVersions.RERANKER_FAILURES_ALLOWED)) {
8283
this.failuresAllowed = in.readBoolean();
8384
} else {
8485
this.failuresAllowed = false;
@@ -102,7 +103,8 @@ public void doWriteTo(StreamOutput out) throws IOException {
102103
out.writeString(inferenceText);
103104
out.writeString(field);
104105
out.writeOptionalFloat(minScore);
105-
if (out.getTransportVersion().onOrAfter(TransportVersions.RERANKER_FAILURES_ALLOWED)) {
106+
if (out.getTransportVersion().isPatchFrom(TransportVersions.RERANKER_FAILURES_ALLOWED_8_19)
107+
|| out.getTransportVersion().onOrAfter(TransportVersions.RERANKER_FAILURES_ALLOWED)) {
106108
out.writeBoolean(failuresAllowed);
107109
}
108110
}

0 commit comments

Comments
 (0)