Skip to content

Commit b02cb1a

Browse files
committed
name fixes
1 parent f9bebe8 commit b02cb1a

File tree

6 files changed

+12
-9
lines changed

6 files changed

+12
-9
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,7 @@ public boolean supports(TransportVersion version) {
258258
}
259259
TransportVersion nextPatchVersion = version.nextPatchVersion;
260260
while (nextPatchVersion != null) {
261-
if (isPatchFrom(version)) {
261+
if (isPatchFrom(nextPatchVersion)) {
262262
return true;
263263
}
264264
nextPatchVersion = nextPatchVersion.nextPatchVersion;

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -338,11 +338,12 @@ static TransportVersion def(int id) {
338338
public static final TransportVersion LOOKUP_JOIN_CCS = def(9_120_0_00);
339339
public static final TransportVersion NODE_USAGE_STATS_FOR_THREAD_POOLS_IN_CLUSTER_INFO = def(9_121_0_00);
340340
public static final TransportVersion ESQL_CATEGORIZE_OPTIONS = def(9_122_0_00);
341+
public static final TransportVersion ML_INFERENCE_AZURE_AI_STUDIO_RERANK_ADDED = def(9_123_0_00);
341342
public static final TransportVersion PROJECT_STATE_REGISTRY_ENTRY = def(9_124_0_00);
342343
public static final TransportVersion ML_INFERENCE_LLAMA_ADDED = def(9_125_0_00);
343344
public static final TransportVersion SHARD_WRITE_LOAD_IN_CLUSTER_INFO = def(9_126_0_00);
344345
public static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS = def(9_127_0_00);
345-
346+
public static final TransportVersion ESQL_TOPN_TIMINGS = def(9_128_0_00);
346347
/*
347348
* STOP! READ THIS FIRST! No, really,
348349
* ____ _____ ___ ____ _ ____ _____ _ ____ _____ _ _ ___ ____ _____ ___ ____ ____ _____ _
Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1 @@
11
esql-split-on-big-values.json
2-
ml-inference-azure-ai-studio-rerank-added.json
3-
esql-topn-timings.json

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/topn/TopNOperatorStatus.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,13 +20,15 @@
2020
import java.io.IOException;
2121
import java.util.Objects;
2222

23+
import static org.elasticsearch.TransportVersions.ESQL_TOPN_TIMINGS;
24+
2325
public class TopNOperatorStatus implements Operator.Status {
2426
public static final NamedWriteableRegistry.Entry ENTRY = new NamedWriteableRegistry.Entry(
2527
Operator.Status.class,
2628
"topn",
2729
TopNOperatorStatus::new
2830
);
29-
public static final TransportVersion ESQL_TOPN_TIMINGS = TransportVersion.fromName("esql-topn-timings");
31+
//public static final TransportVersion ESQL_TOPN_TIMINGS = TransportVersion.fromName("esql-topn-timings");
3032
private final long receiveNanos;
3133
private final long emitNanos;
3234
private final int occupiedRows;
@@ -57,7 +59,7 @@ public TopNOperatorStatus(
5759
}
5860

5961
TopNOperatorStatus(StreamInput in) throws IOException {
60-
if (in.getTransportVersion().supports(ESQL_TOPN_TIMINGS)) {
62+
if (in.getTransportVersion().onOrAfter(ESQL_TOPN_TIMINGS)) {
6163
this.receiveNanos = in.readVLong();
6264
this.emitNanos = in.readVLong();
6365
} else {
@@ -82,7 +84,7 @@ public TopNOperatorStatus(
8284

8385
@Override
8486
public void writeTo(StreamOutput out) throws IOException {
85-
if (out.getTransportVersion().supports(ESQL_TOPN_TIMINGS)) {
87+
if (out.getTransportVersion().onOrAfter(ESQL_TOPN_TIMINGS)) {
8688
out.writeVLong(receiveNanos);
8789
out.writeVLong(emitNanos);
8890
}

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/azureaistudio/rerank/AzureAiStudioRerankServiceSettings.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
package org.elasticsearch.xpack.inference.services.azureaistudio.rerank;
99

1010
import org.elasticsearch.TransportVersion;
11+
import org.elasticsearch.TransportVersions;
1112
import org.elasticsearch.common.ValidationException;
1213
import org.elasticsearch.common.io.stream.StreamInput;
1314
import org.elasticsearch.common.io.stream.StreamOutput;
@@ -79,7 +80,7 @@ public String getWriteableName() {
7980

8081
@Override
8182
public TransportVersion getMinimalSupportedVersion() {
82-
return TransportVersion.fromName("ml-inference-azure-ai-studio-rerank-added");
83+
return TransportVersions.ML_INFERENCE_AZURE_AI_STUDIO_RERANK_ADDED;//TransportVersion.fromName("ml-inference-azure-ai-studio-rerank-added");
8384
}
8485

8586
@Override

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/azureaistudio/rerank/AzureAiStudioRerankTaskSettings.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
package org.elasticsearch.xpack.inference.services.azureaistudio.rerank;
99

1010
import org.elasticsearch.TransportVersion;
11+
import org.elasticsearch.TransportVersions;
1112
import org.elasticsearch.common.ValidationException;
1213
import org.elasticsearch.common.io.stream.StreamInput;
1314
import org.elasticsearch.common.io.stream.StreamOutput;
@@ -93,7 +94,7 @@ public String getWriteableName() {
9394

9495
@Override
9596
public TransportVersion getMinimalSupportedVersion() {
96-
return TransportVersion.fromName("ml-inference-azure-ai-studio-rerank-added");
97+
return TransportVersions.ML_INFERENCE_AZURE_AI_STUDIO_RERANK_ADDED;//TransportVersion.fromName("ml-inference-azure-ai-studio-rerank-added");
9798
}
9899

99100
@Override

0 commit comments

Comments
 (0)