Skip to content

Commit 3385788

Browse files
jdconradjdconrad
committed
Migrate transport versions 9108_000 through 9086_000 (elastic#135819)
Note some versions in between have already been migrated. ES-12334
1 parent 5377b9b commit 3385788

File tree

32 files changed

+127
-85
lines changed

32 files changed

+127
-85
lines changed

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

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -181,8 +181,6 @@ static TransportVersion def(int id) {
181181
public static final TransportVersion REMOVE_ALL_APPLICABLE_SELECTOR_9_0 = def(9_000_0_05);
182182
public static final TransportVersion BYTE_SIZE_VALUE_ALWAYS_USES_BYTES_90 = def(9_000_0_06);
183183
public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_90 = def(9_000_0_07);
184-
public static final TransportVersion RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90 = def(9_000_0_08);
185-
public static final TransportVersion STORED_SCRIPT_CONTENT_LENGTH_90 = def(9_000_0_09);
186184
public static final TransportVersion COHERE_BIT_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_001_0_00);
187185
public static final TransportVersion REMOVE_SNAPSHOT_FAILURES = def(9_002_0_00);
188186
public static final TransportVersion TRANSPORT_STATS_HANDLING_TIME_REQUIRED = def(9_003_0_00);
@@ -200,9 +198,7 @@ static TransportVersion def(int id) {
200198
public static final TransportVersion ESQL_SERIALIZE_SOURCE_FUNCTIONS_WARNINGS = def(9_016_0_00);
201199
public static final TransportVersion ESQL_DRIVER_NODE_DESCRIPTION = def(9_017_0_00);
202200
public static final TransportVersion MULTI_PROJECT = def(9_018_0_00);
203-
public static final TransportVersion STORED_SCRIPT_CONTENT_LENGTH = def(9_019_0_00);
204201
public static final TransportVersion JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_020_0_00);
205-
public static final TransportVersion RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE = def(9_021_0_00);
206202
public static final TransportVersion UNASSIGENEDINFO_RESHARD_ADDED = def(9_022_0_00);
207203
public static final TransportVersion MAX_OPERATION_SIZE_REJECTIONS_ADDED = def(9_024_0_00);
208204
public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR = def(9_025_0_00);
@@ -252,14 +248,6 @@ static TransportVersion def(int id) {
252248
public static final TransportVersion ESQL_TIME_SERIES_SOURCE_STATUS = def(9_076_0_00);
253249
public static final TransportVersion NODES_STATS_SUPPORTS_MULTI_PROJECT = def(9_079_0_00);
254250
public static final TransportVersion ESQL_LIMIT_ROW_SIZE = def(9_085_0_00);
255-
public static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = def(9_093_0_00);
256-
public static final TransportVersion SEARCH_LOAD_PER_INDEX_STATS = def(9_095_0_00);
257-
public static final TransportVersion HEAP_USAGE_IN_CLUSTER_INFO = def(9_096_0_00);
258-
public static final TransportVersion PROJECT_DELETION_GLOBAL_BLOCK = def(9_098_0_00);
259-
public static final TransportVersion SECURITY_CLOUD_API_KEY_REALM_AND_TYPE = def(9_099_0_00);
260-
public static final TransportVersion STATE_PARAM_GET_SNAPSHOT = def(9_100_0_00);
261-
public static final TransportVersion PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP = def(9_101_0_00);
262-
public static final TransportVersion CLUSTER_STATE_PROJECTS_SETTINGS = def(9_108_0_00);
263251

264252
/*
265253
* STOP! READ THIS FIRST! No, really,

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/get/GetSnapshotsRequest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public class GetSnapshotsRequest extends MasterNodeRequest<GetSnapshotsRequest>
4242
public static final boolean DEFAULT_VERBOSE_MODE = true;
4343

4444
private static final TransportVersion INDICES_FLAG_VERSION = TransportVersions.V_8_3_0;
45-
private static final TransportVersion STATE_FLAG_VERSION = TransportVersions.STATE_PARAM_GET_SNAPSHOT;
45+
private static final TransportVersion STATE_FLAG_VERSION = TransportVersion.fromName("state_param_get_snapshot");
4646

4747
public static final int NO_LIMIT = -1;
4848

@@ -124,7 +124,7 @@ public GetSnapshotsRequest(StreamInput in) throws IOException {
124124
if (in.getTransportVersion().onOrAfter(INDICES_FLAG_VERSION)) {
125125
includeIndexNames = in.readBoolean();
126126
}
127-
if (in.getTransportVersion().onOrAfter(STATE_FLAG_VERSION)) {
127+
if (in.getTransportVersion().supports(STATE_FLAG_VERSION)) {
128128
states = in.readEnumSet(SnapshotState.class);
129129
} else {
130130
states = EnumSet.allOf(SnapshotState.class);
@@ -148,7 +148,7 @@ public void writeTo(StreamOutput out) throws IOException {
148148
if (out.getTransportVersion().onOrAfter(INDICES_FLAG_VERSION)) {
149149
out.writeBoolean(includeIndexNames);
150150
}
151-
if (out.getTransportVersion().onOrAfter(STATE_FLAG_VERSION)) {
151+
if (out.getTransportVersion().supports(STATE_FLAG_VERSION)) {
152152
out.writeEnumSet(states);
153153
} else if (states.equals(EnumSet.allOf(SnapshotState.class)) == false) {
154154
final var errorString = "GetSnapshotsRequest [states] field is not supported on all nodes in the cluster";

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/status/SnapshotIndexShardStatus.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.admin.cluster.snapshots.status;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.action.support.broadcast.BroadcastShardResponse;
1314
import org.elasticsearch.common.Strings;
1415
import org.elasticsearch.common.io.stream.StreamInput;
@@ -22,10 +23,12 @@
2223
import java.io.IOException;
2324
import java.util.Objects;
2425

25-
import static org.elasticsearch.TransportVersions.SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS;
26-
2726
public class SnapshotIndexShardStatus extends BroadcastShardResponse implements ToXContentFragment {
2827

28+
private static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = TransportVersion.fromName(
29+
"snapshot_index_shard_status_missing_stats"
30+
);
31+
2932
private final SnapshotIndexShardStage stage;
3033

3134
private final SnapshotStats stats;
@@ -42,7 +45,7 @@ public SnapshotIndexShardStatus(StreamInput in) throws IOException {
4245
stats = new SnapshotStats(in);
4346
nodeId = in.readOptionalString();
4447
failure = in.readOptionalString();
45-
if (in.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
48+
if (in.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
4649
description = in.readOptionalString();
4750
}
4851
}
@@ -159,7 +162,7 @@ public void writeTo(StreamOutput out) throws IOException {
159162
stats.writeTo(out);
160163
out.writeOptionalString(nodeId);
161164
out.writeOptionalString(failure);
162-
if (out.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
165+
if (out.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
163166
out.writeOptionalString(description);
164167
}
165168
}

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/status/SnapshotStats.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.admin.cluster.snapshots.status;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.common.Strings;
1314
import org.elasticsearch.common.io.stream.StreamInput;
1415
import org.elasticsearch.common.io.stream.StreamOutput;
@@ -21,10 +22,12 @@
2122

2223
import java.io.IOException;
2324

24-
import static org.elasticsearch.TransportVersions.SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS;
25-
2625
public class SnapshotStats implements Writeable, ToXContentObject {
2726

27+
private static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = TransportVersion.fromName(
28+
"snapshot_index_shard_status_missing_stats"
29+
);
30+
2831
private long startTime;
2932
private long time;
3033
private int incrementalFileCount;
@@ -38,7 +41,7 @@ public class SnapshotStats implements Writeable, ToXContentObject {
3841

3942
SnapshotStats(StreamInput in) throws IOException {
4043
// We use a boolean to indicate if the stats are present (true) or missing (false), to skip writing all the values if missing.
41-
if (in.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS) && in.readBoolean() == false) {
44+
if (in.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS) && in.readBoolean() == false) {
4245
startTime = 0L;
4346
time = 0L;
4447
incrementalFileCount = -1;
@@ -156,7 +159,7 @@ public long getProcessedSize() {
156159

157160
@Override
158161
public void writeTo(StreamOutput out) throws IOException {
159-
if (out.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
162+
if (out.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
160163
// We use a boolean to indicate if the stats are present (true) or missing (false), to skip writing all the values if missing.
161164
if (isMissingStats()) {
162165
out.writeBoolean(false);

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/status/TransportSnapshotsStatusAction.java‎

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import org.apache.logging.log4j.LogManager;
1313
import org.apache.logging.log4j.Logger;
1414
import org.elasticsearch.TransportVersion;
15-
import org.elasticsearch.TransportVersions;
1615
import org.elasticsearch.action.ActionListener;
1716
import org.elasticsearch.action.ActionType;
1817
import org.elasticsearch.action.support.ActionFilters;
@@ -73,6 +72,10 @@ public class TransportSnapshotsStatusAction extends TransportMasterNodeAction<Sn
7372
public static final ActionType<SnapshotsStatusResponse> TYPE = new ActionType<>("cluster:admin/snapshot/status");
7473
private static final Logger logger = LogManager.getLogger(TransportSnapshotsStatusAction.class);
7574

75+
private static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = TransportVersion.fromName(
76+
"snapshot_index_shard_status_missing_stats"
77+
);
78+
7679
private final RepositoriesService repositoriesService;
7780

7881
private final NodeClient client;
@@ -245,7 +248,7 @@ void buildResponse(
245248
// When processing currently running snapshots, instead of reading the statistics from the repository, which can be
246249
// expensive, we choose instead to provide a message to the caller explaining why the stats are missing and the API
247250
// that can be used to load them once the snapshot has completed.
248-
if (minTransportVersion.onOrAfter(TransportVersions.SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
251+
if (minTransportVersion.supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
249252
shardStatus = SnapshotIndexShardStatus.forDoneButMissingStats(shardId, """
250253
Snapshot shard stats missing from a currently running snapshot due to a node leaving the cluster after \
251254
completing the shard snapshot; retry once the snapshot has completed to load all shard stats from the \

‎server/src/main/java/org/elasticsearch/action/admin/cluster/storedscripts/PutStoredScriptRequest.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99

1010
package org.elasticsearch.action.admin.cluster.storedscripts;
1111

12-
import org.elasticsearch.TransportVersions;
12+
import org.elasticsearch.TransportVersion;
1313
import org.elasticsearch.action.ActionRequestValidationException;
1414
import org.elasticsearch.action.support.master.AcknowledgedRequest;
1515
import org.elasticsearch.common.Strings;
@@ -32,6 +32,8 @@
3232

3333
public class PutStoredScriptRequest extends AcknowledgedRequest<PutStoredScriptRequest> implements ToXContentFragment {
3434

35+
private static final TransportVersion STORED_SCRIPT_CONTENT_LENGTH = TransportVersion.fromName("stored_script_content_length");
36+
3537
@Nullable
3638
private final String id;
3739

@@ -45,8 +47,7 @@ public class PutStoredScriptRequest extends AcknowledgedRequest<PutStoredScriptR
4547
public PutStoredScriptRequest(StreamInput in) throws IOException {
4648
super(in);
4749
id = in.readOptionalString();
48-
if (in.getTransportVersion().isPatchFrom(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH_90)
49-
|| in.getTransportVersion().onOrAfter(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH)) {
50+
if (in.getTransportVersion().supports(STORED_SCRIPT_CONTENT_LENGTH)) {
5051
contentLength = in.readVInt();
5152
} else {
5253
BytesReference content = in.readBytesReference();
@@ -106,8 +107,7 @@ public StoredScriptSource source() {
106107
public void writeTo(StreamOutput out) throws IOException {
107108
super.writeTo(out);
108109
out.writeOptionalString(id);
109-
if (out.getTransportVersion().isPatchFrom(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH_90)
110-
|| out.getTransportVersion().onOrAfter(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH)) {
110+
if (out.getTransportVersion().supports(STORED_SCRIPT_CONTENT_LENGTH)) {
111111
out.writeVInt(contentLength);
112112
} else {
113113
// generate a bytes reference of the correct size (the content isn't actually used in 8.18)

‎server/src/main/java/org/elasticsearch/action/search/SearchRequest.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.search;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.TransportVersions;
1314
import org.elasticsearch.Version;
1415
import org.elasticsearch.action.ActionRequestValidationException;
@@ -62,6 +63,10 @@ public class SearchRequest extends LegacyActionRequest implements IndicesRequest
6263

6364
private static final long DEFAULT_ABSOLUTE_START_MILLIS = -1;
6465

66+
private static final TransportVersion RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE = TransportVersion.fromName(
67+
"re_remove_min_compatible_shard_node"
68+
);
69+
6570
private final String localClusterAlias;
6671
private final long absoluteStartMillis;
6772
private final boolean finalReduce;
@@ -254,8 +259,7 @@ public SearchRequest(StreamInput in) throws IOException {
254259
finalReduce = true;
255260
}
256261
ccsMinimizeRoundtrips = in.readBoolean();
257-
if ((in.getTransportVersion().isPatchFrom(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90) == false
258-
&& in.getTransportVersion().before(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE)) && in.readBoolean()) {
262+
if (in.getTransportVersion().supports(RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE) == false && in.readBoolean()) {
259263
Version.readVersion(in); // and drop on the floor
260264
}
261265
waitForCheckpoints = in.readMap(StreamInput::readLongArray);
@@ -299,8 +303,7 @@ public void writeTo(StreamOutput out, boolean skipIndices) throws IOException {
299303
out.writeBoolean(finalReduce);
300304
}
301305
out.writeBoolean(ccsMinimizeRoundtrips);
302-
if ((out.getTransportVersion().isPatchFrom(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90) == false
303-
&& out.getTransportVersion().before(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE))) {
306+
if (out.getTransportVersion().supports(RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE) == false) {
304307
out.writeBoolean(false);
305308
}
306309
out.writeMap(waitForCheckpoints, StreamOutput::writeLongArray);

‎server/src/main/java/org/elasticsearch/cluster/ClusterInfo.java‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ public class ClusterInfo implements ChunkedToXContent, Writeable {
5050
public static final ClusterInfo EMPTY = new ClusterInfo();
5151

5252
public static final TransportVersion DATA_PATH_NEW_KEY_VERSION = TransportVersions.V_8_6_0;
53+
private static final TransportVersion HEAP_USAGE_IN_CLUSTER_INFO = TransportVersion.fromName("heap_usage_in_cluster_info");
5354

5455
private final Map<String, DiskUsage> leastAvailableSpaceUsage;
5556
private final Map<String, DiskUsage> mostAvailableSpaceUsage;
@@ -102,7 +103,7 @@ public ClusterInfo(StreamInput in) throws IOException {
102103
? in.readImmutableMap(NodeAndShard::new, StreamInput::readString)
103104
: in.readImmutableMap(nested -> NodeAndShard.from(new ShardRouting(nested)), StreamInput::readString);
104105
this.reservedSpace = in.readImmutableMap(NodeAndPath::new, ReservedSpace::new);
105-
if (in.getTransportVersion().onOrAfter(TransportVersions.HEAP_USAGE_IN_CLUSTER_INFO)) {
106+
if (in.getTransportVersion().supports(HEAP_USAGE_IN_CLUSTER_INFO)) {
106107
this.estimatedHeapUsages = in.readImmutableMap(EstimatedHeapUsage::new);
107108
} else {
108109
this.estimatedHeapUsages = Map.of();
@@ -121,7 +122,7 @@ public void writeTo(StreamOutput out) throws IOException {
121122
out.writeMap(this.dataPath, (o, k) -> createFakeShardRoutingFromNodeAndShard(k).writeTo(o), StreamOutput::writeString);
122123
}
123124
out.writeMap(this.reservedSpace);
124-
if (out.getTransportVersion().onOrAfter(TransportVersions.HEAP_USAGE_IN_CLUSTER_INFO)) {
125+
if (out.getTransportVersion().supports(HEAP_USAGE_IN_CLUSTER_INFO)) {
125126
out.writeMap(this.estimatedHeapUsages, StreamOutput::writeWriteable);
126127
}
127128
}

‎server/src/main/java/org/elasticsearch/cluster/RepositoryCleanupInProgress.java‎

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,6 @@
2323
import java.util.List;
2424
import java.util.Objects;
2525

26-
import static org.elasticsearch.TransportVersions.PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP;
27-
2826
/**
2927
* A repository cleanup request entry. Part of the cluster state.
3028
*/
@@ -34,6 +32,10 @@ public final class RepositoryCleanupInProgress extends AbstractNamedDiffable<Clu
3432

3533
public static final String TYPE = "repository_cleanup";
3634

35+
private static final TransportVersion PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP = TransportVersion.fromName(
36+
"project_id_in_snapshots_deletions_and_repo_cleanup"
37+
);
38+
3739
private final List<Entry> entries;
3840

3941
public static RepositoryCleanupInProgress get(ClusterState state) {
@@ -114,7 +116,7 @@ public TransportVersion getMinimalSupportedVersion() {
114116
public record Entry(ProjectId projectId, String repository, long repositoryStateId) implements Writeable, RepositoryOperation {
115117

116118
public static Entry readFrom(StreamInput in) throws IOException {
117-
final ProjectId projectId = in.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
119+
final ProjectId projectId = in.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
118120
? ProjectId.readFrom(in)
119121
: ProjectId.DEFAULT;
120122
return new Entry(projectId, in.readString(), in.readLong());
@@ -137,7 +139,7 @@ public String repository() {
137139

138140
@Override
139141
public void writeTo(StreamOutput out) throws IOException {
140-
if (out.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
142+
if (out.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
141143
projectId.writeTo(out);
142144
} else {
143145
if (ProjectId.DEFAULT.equals(projectId) == false) {

‎server/src/main/java/org/elasticsearch/cluster/SnapshotDeletionsInProgress.java‎

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,6 @@
3232
import java.util.List;
3333
import java.util.Set;
3434

35-
import static org.elasticsearch.TransportVersions.PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP;
36-
3735
/**
3836
* Represents the in-progress snapshot deletions in the cluster state.
3937
*/
@@ -43,6 +41,10 @@ public class SnapshotDeletionsInProgress extends AbstractNamedDiffable<Custom> i
4341

4442
public static final String TYPE = "snapshot_deletions";
4543

44+
private static final TransportVersion PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP = TransportVersion.fromName(
45+
"project_id_in_snapshots_deletions_and_repo_cleanup"
46+
);
47+
4648
// the list of snapshot deletion request entries
4749
private final List<Entry> entries;
4850

@@ -237,7 +239,7 @@ public Entry(
237239

238240
@SuppressForbidden(reason = "using a private constructor within the same file")
239241
public static Entry readFrom(StreamInput in) throws IOException {
240-
final ProjectId projectId = in.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
242+
final ProjectId projectId = in.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
241243
? ProjectId.readFrom(in)
242244
: ProjectId.DEFAULT;
243245
return new Entry(
@@ -279,7 +281,7 @@ public Entry withRepoGen(long repoGen) {
279281

280282
@Override
281283
public void writeTo(StreamOutput out) throws IOException {
282-
if (out.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
284+
if (out.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
283285
projectId.writeTo(out);
284286
} else {
285287
if (ProjectId.DEFAULT.equals(projectId) == false) {

0 commit comments

Comments
 (0)