Skip to content

Commit 9ffc114

Browse files
jdconradjdconrad
committed
Migrate transport versions 8841_030 through 8841_000 (elastic#135974)
ES-12334
1 parent 0e49dbd commit 9ffc114

File tree

91 files changed

+331
-377
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

91 files changed

+331
-377
lines changed

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

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1968,13 +1968,7 @@ private enum ElasticsearchExceptionHandle {
19681968
183,
19691969
TransportVersions.V_8_16_0
19701970
),
1971-
REMOTE_EXCEPTION(
1972-
RemoteException.class,
1973-
RemoteException::new,
1974-
184,
1975-
TransportVersions.REMOTE_EXCEPTION,
1976-
TransportVersions.REMOTE_EXCEPTION_8_19
1977-
);
1971+
REMOTE_EXCEPTION(RemoteException.class, RemoteException::new, 184, TransportVersion.minimumCompatible());
19781972

19791973
final Class<? extends ElasticsearchException> exceptionClass;
19801974
final CheckedFunction<StreamInput, ? extends ElasticsearchException, IOException> constructor;

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

Lines changed: 0 additions & 66 deletions
Original file line numberDiff line numberDiff line change
@@ -140,100 +140,34 @@ static TransportVersion def(int id) {
140140
public static final TransportVersion TIMEOUT_GET_PARAM_FOR_RESOLVE_CLUSTER = def(8_838_0_00);
141141
public static final TransportVersion INFERENCE_REQUEST_ADAPTIVE_RATE_LIMITING = def(8_839_0_00);
142142
public static final TransportVersion ML_INFERENCE_IBM_WATSONX_RERANK_ADDED = def(8_840_0_00);
143-
// TODO: add to remove_all_applicable_selector.csv
144-
public static final TransportVersion REMOVE_ALL_APPLICABLE_SELECTOR_BACKPORT_8_18 = def(8_840_0_01);
145-
// TODO: add to retry_ilm_async_action_require_error.csv
146-
public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_18 = def(8_840_0_02);
147-
public static final TransportVersion INITIAL_ELASTICSEARCH_8_19 = def(8_841_0_00);
148-
public static final TransportVersion COHERE_BIT_EMBEDDING_TYPE_SUPPORT_ADDED_BACKPORT_8_X = def(8_841_0_01);
149-
// TODO: add to remove_all_applicable_selector.csv
150-
public static final TransportVersion REMOVE_ALL_APPLICABLE_SELECTOR_BACKPORT_8_19 = def(8_841_0_02);
151-
public static final TransportVersion ESQL_RETRY_ON_SHARD_LEVEL_FAILURE_BACKPORT_8_19 = def(8_841_0_03);
152-
public static final TransportVersion ESQL_SUPPORT_PARTIAL_RESULTS_BACKPORT_8_19 = def(8_841_0_04);
153-
public static final TransportVersion VOYAGE_AI_INTEGRATION_ADDED_BACKPORT_8_X = def(8_841_0_05);
154-
public static final TransportVersion JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED_BACKPORT_8_19 = def(8_841_0_06);
155-
// TODO: add to retry_ilm_async_action_require_error.csv
156-
public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_19 = def(8_841_0_07);
157-
public static final TransportVersion INFERENCE_CONTEXT_8_X = def(8_841_0_08);
158-
public static final TransportVersion ML_INFERENCE_DEEPSEEK_8_19 = def(8_841_0_09);
159-
public static final TransportVersion ESQL_SERIALIZE_BLOCK_TYPE_CODE_8_19 = def(8_841_0_10);
160-
public static final TransportVersion ESQL_FAILURE_FROM_REMOTE_8_19 = def(8_841_0_11);
161-
public static final TransportVersion ESQL_AGGREGATE_METRIC_DOUBLE_LITERAL_8_19 = def(8_841_0_12);
162-
public static final TransportVersion INFERENCE_MODEL_REGISTRY_METADATA_8_19 = def(8_841_0_13);
163-
public static final TransportVersion INTRODUCE_LIFECYCLE_TEMPLATE_8_19 = def(8_841_0_14);
164-
public static final TransportVersion RERANK_COMMON_OPTIONS_ADDED_8_19 = def(8_841_0_15);
165-
public static final TransportVersion REMOTE_EXCEPTION_8_19 = def(8_841_0_16);
166-
public static final TransportVersion AMAZON_BEDROCK_TASK_SETTINGS_8_19 = def(8_841_0_17);
167-
public static final TransportVersion SEMANTIC_TEXT_CHUNKING_CONFIG_8_19 = def(8_841_0_18);
168-
public static final TransportVersion BATCHED_QUERY_PHASE_VERSION_BACKPORT_8_X = def(8_841_0_19);
169-
public static final TransportVersion SEARCH_INCREMENTAL_TOP_DOCS_NULL_BACKPORT_8_19 = def(8_841_0_20);
170-
public static final TransportVersion ML_INFERENCE_SAGEMAKER_8_19 = def(8_841_0_21);
171-
public static final TransportVersion ESQL_REPORT_ORIGINAL_TYPES_BACKPORT_8_19 = def(8_841_0_22);
172-
public static final TransportVersion PINNED_RETRIEVER_8_19 = def(8_841_0_23);
173-
public static final TransportVersion ESQL_AGGREGATE_METRIC_DOUBLE_BLOCK_8_19 = def(8_841_0_24);
174-
public static final TransportVersion INTRODUCE_FAILURES_LIFECYCLE_BACKPORT_8_19 = def(8_841_0_25);
175-
public static final TransportVersion INTRODUCE_FAILURES_DEFAULT_RETENTION_BACKPORT_8_19 = def(8_841_0_26);
176-
public static final TransportVersion RESCORE_VECTOR_ALLOW_ZERO_BACKPORT_8_19 = def(8_841_0_27);
177-
public static final TransportVersion INFERENCE_ADD_TIMEOUT_PUT_ENDPOINT_8_19 = def(8_841_0_28);
178-
public static final TransportVersion ESQL_REPORT_SHARD_PARTITIONING_8_19 = def(8_841_0_29);
179-
// TODO: add to esql_driver_task_description.csv
180-
public static final TransportVersion ESQL_DRIVER_TASK_DESCRIPTION_8_19 = def(8_841_0_30);
181-
public static final TransportVersion COHERE_BIT_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_001_0_00);
182-
public static final TransportVersion ESQL_RETRY_ON_SHARD_LEVEL_FAILURE = def(9_006_0_00);
183143
public static final TransportVersion ESQL_PROFILE_ASYNC_NANOS = def(9_007_00_0);
184144
public static final TransportVersion ESQL_LOOKUP_JOIN_SOURCE_TEXT = def(9_008_0_00);
185145
public static final TransportVersion SLM_UNHEALTHY_IF_NO_SNAPSHOT_WITHIN = def(9_010_0_00);
186-
public static final TransportVersion ESQL_SUPPORT_PARTIAL_RESULTS = def(9_011_0_00);
187146
public static final TransportVersion REMOVE_REPOSITORY_CONFLICT_MESSAGE = def(9_012_0_00);
188-
public static final TransportVersion VOYAGE_AI_INTEGRATION_ADDED = def(9_014_0_00);
189147
public static final TransportVersion ESQL_SERIALIZE_SOURCE_FUNCTIONS_WARNINGS = def(9_016_0_00);
190148
public static final TransportVersion ESQL_DRIVER_NODE_DESCRIPTION = def(9_017_0_00);
191149
public static final TransportVersion MULTI_PROJECT = def(9_018_0_00);
192-
public static final TransportVersion JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_020_0_00);
193150
public static final TransportVersion UNASSIGENEDINFO_RESHARD_ADDED = def(9_022_0_00);
194151
public static final TransportVersion MAX_OPERATION_SIZE_REJECTIONS_ADDED = def(9_024_0_00);
195-
public static final TransportVersion ESQL_SERIALIZE_BLOCK_TYPE_CODE = def(9_026_0_00);
196152
public static final TransportVersion ESQL_THREAD_NAME_IN_DRIVER_PROFILE = def(9_027_0_00);
197-
public static final TransportVersion INFERENCE_CONTEXT = def(9_028_0_00);
198-
public static final TransportVersion ML_INFERENCE_DEEPSEEK = def(9_029_00_0);
199-
public static final TransportVersion ESQL_FAILURE_FROM_REMOTE = def(9_030_00_0);
200153
public static final TransportVersion INDEX_RESHARDING_METADATA = def(9_031_0_00);
201-
public static final TransportVersion INFERENCE_MODEL_REGISTRY_METADATA = def(9_032_0_00);
202-
public static final TransportVersion INTRODUCE_LIFECYCLE_TEMPLATE = def(9_033_0_00);
203154
public static final TransportVersion INDEXING_STATS_INCLUDES_RECENT_WRITE_LOAD = def(9_034_0_00);
204-
public static final TransportVersion ESQL_AGGREGATE_METRIC_DOUBLE_LITERAL = def(9_035_0_00);
205155
public static final TransportVersion INDEX_METADATA_INCLUDES_RECENT_WRITE_LOAD = def(9_036_0_00);
206-
public static final TransportVersion RERANK_COMMON_OPTIONS_ADDED = def(9_037_0_00);
207-
public static final TransportVersion ESQL_REPORT_ORIGINAL_TYPES = def(9_038_00_0);
208-
public static final TransportVersion RESCORE_VECTOR_ALLOW_ZERO = def(9_039_0_00);
209156
public static final TransportVersion PROJECT_ID_IN_SNAPSHOT = def(9_040_0_00);
210157
public static final TransportVersion INDEX_STATS_AND_METADATA_INCLUDE_PEAK_WRITE_LOAD = def(9_041_0_00);
211-
public static final TransportVersion BATCHED_QUERY_PHASE_VERSION = def(9_043_0_00);
212-
public static final TransportVersion REMOTE_EXCEPTION = def(9_044_0_00);
213158
public static final TransportVersion ESQL_REMOVE_AGGREGATE_TYPE = def(9_045_0_00);
214159
public static final TransportVersion ADD_PROJECT_ID_TO_DSL_ERROR_INFO = def(9_046_0_00);
215-
public static final TransportVersion SEMANTIC_TEXT_CHUNKING_CONFIG = def(9_047_0_00);
216160
public static final TransportVersion REPO_ANALYSIS_COPY_BLOB = def(9_048_0_00);
217-
public static final TransportVersion AMAZON_BEDROCK_TASK_SETTINGS = def(9_049_0_00);
218-
public static final TransportVersion ESQL_REPORT_SHARD_PARTITIONING = def(9_050_0_00);
219161
public static final TransportVersion DEAD_ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED = def(9_052_0_00);
220162
public static final TransportVersion DEAD_BATCHED_QUERY_EXECUTION_DELAYABLE_WRITABLE = def(9_053_0_00);
221-
public static final TransportVersion DEAD_SEARCH_INCREMENTAL_TOP_DOCS_NULL = def(9_054_0_00);
222163
public static final TransportVersion BATCHED_QUERY_EXECUTION_DELAYABLE_WRITABLE = def(9_057_0_00);
223-
public static final TransportVersion SEARCH_INCREMENTAL_TOP_DOCS_NULL = def(9_058_0_00);
224164
public static final TransportVersion COMPRESS_DELAYABLE_WRITEABLE = def(9_059_0_00);
225165
public static final TransportVersion SYNONYMS_REFRESH_PARAM = def(9_060_0_00);
226166
public static final TransportVersion DOC_FIELDS_AS_LIST = def(9_061_0_00);
227167
public static final TransportVersion DENSE_VECTOR_OFF_HEAP_STATS = def(9_062_00_0);
228-
public static final TransportVersion INTRODUCE_FAILURES_LIFECYCLE = def(9_065_0_00);
229168
public static final TransportVersion PROJECT_METADATA_SETTINGS = def(9_066_0_00);
230-
public static final TransportVersion AGGREGATE_METRIC_DOUBLE_BLOCK = def(9_067_0_00);
231-
public static final TransportVersion PINNED_RETRIEVER = def(9_068_0_00);
232-
public static final TransportVersion ML_INFERENCE_SAGEMAKER = def(9_069_0_00);
233169
public static final TransportVersion WRITE_LOAD_INCLUDES_BUFFER_WRITES = def(9_070_0_00);
234-
public static final TransportVersion INTRODUCE_FAILURES_DEFAULT_RETENTION = def(9_071_0_00);
235170
public static final TransportVersion FILE_SETTINGS_HEALTH_INFO = def(9_072_0_00);
236-
public static final TransportVersion INFERENCE_ADD_TIMEOUT_PUT_ENDPOINT = def(9_074_0_00);
237171
public static final TransportVersion ESQL_FIELD_ATTRIBUTE_DROP_TYPE = def(9_075_0_00);
238172
public static final TransportVersion ESQL_TIME_SERIES_SOURCE_STATUS = def(9_076_0_00);
239173
public static final TransportVersion NODES_STATS_SUPPORTS_MULTI_PROJECT = def(9_079_0_00);

‎server/src/main/java/org/elasticsearch/action/datastreams/GetDataStreamAction.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,6 +210,9 @@ public enum ManagedBy {
210210

211211
public static final ParseField DATA_STREAMS_FIELD = new ParseField("data_streams");
212212

213+
private static final TransportVersion INTRODUCE_FAILURES_DEFAULT_RETENTION_PATCH = TransportVersion.fromName(
214+
"introduce_failures_default_retention"
215+
).nextPatchVersion();
213216
private static final TransportVersion INCLUDE_INDEX_MODE_IN_GET_DATA_STREAM = TransportVersion.fromName(
214217
"include_index_mode_in_get_data_stream"
215218
);
@@ -658,7 +661,7 @@ public void writeTo(StreamOutput out) throws IOException {
658661
out.writeOptionalWriteable(rolloverConfiguration);
659662
}
660663
// A version 9.x cluster will never read this, so we only need to include the patch version here.
661-
if (out.getTransportVersion().isPatchFrom(TransportVersions.INTRODUCE_FAILURES_DEFAULT_RETENTION_BACKPORT_8_19)) {
664+
if (out.getTransportVersion().supports(INTRODUCE_FAILURES_DEFAULT_RETENTION_PATCH)) {
662665
out.writeOptionalTimeValue(dataGlobalRetention == null ? null : dataGlobalRetention.defaultRetention());
663666
out.writeOptionalTimeValue(dataGlobalRetention == null ? null : dataGlobalRetention.maxRetention());
664667
out.writeOptionalTimeValue(failuresGlobalRetention == null ? null : failuresGlobalRetention.defaultRetention());

‎server/src/main/java/org/elasticsearch/action/datastreams/lifecycle/ExplainDataStreamLifecycleAction.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.datastreams.lifecycle;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.TransportVersions;
1314
import org.elasticsearch.action.ActionRequestValidationException;
1415
import org.elasticsearch.action.ActionResponse;
@@ -143,6 +144,10 @@ public Request indicesOptions(IndicesOptions indicesOptions) {
143144
*/
144145
public static class Response extends ActionResponse implements ChunkedToXContentObject {
145146
public static final ParseField INDICES_FIELD = new ParseField("indices");
147+
private static final TransportVersion INTRODUCE_FAILURES_DEFAULT_RETENTION = TransportVersion.fromName(
148+
"" + "introduce_failures_default_retention"
149+
);
150+
146151
private final List<ExplainIndexDataStreamLifecycle> indices;
147152
@Nullable
148153
private final RolloverConfiguration rolloverConfiguration;
@@ -166,8 +171,7 @@ public Response(
166171
public Response(StreamInput in) throws IOException {
167172
this.indices = in.readCollectionAsList(ExplainIndexDataStreamLifecycle::new);
168173
this.rolloverConfiguration = in.readOptionalWriteable(RolloverConfiguration::new);
169-
if (in.getTransportVersion().onOrAfter(TransportVersions.INTRODUCE_FAILURES_DEFAULT_RETENTION)
170-
|| in.getTransportVersion().isPatchFrom(TransportVersions.INTRODUCE_FAILURES_DEFAULT_RETENTION_BACKPORT_8_19)) {
174+
if (in.getTransportVersion().supports(INTRODUCE_FAILURES_DEFAULT_RETENTION)) {
171175
var defaultRetention = in.readOptionalTimeValue();
172176
var maxRetention = in.readOptionalTimeValue();
173177
var defaultFailuresRetention = in.readOptionalTimeValue();
@@ -209,8 +213,7 @@ private DataStreamGlobalRetention getGlobalRetentionForLifecycle(DataStreamLifec
209213
public void writeTo(StreamOutput out) throws IOException {
210214
out.writeCollection(indices);
211215
out.writeOptionalWriteable(rolloverConfiguration);
212-
if (out.getTransportVersion().onOrAfter(TransportVersions.INTRODUCE_FAILURES_DEFAULT_RETENTION)
213-
|| out.getTransportVersion().isPatchFrom(TransportVersions.INTRODUCE_FAILURES_DEFAULT_RETENTION_BACKPORT_8_19)) {
216+
if (out.getTransportVersion().supports(INTRODUCE_FAILURES_DEFAULT_RETENTION)) {
214217
out.writeOptionalTimeValue(dataGlobalRetention == null ? null : dataGlobalRetention.defaultRetention());
215218
out.writeOptionalTimeValue(dataGlobalRetention == null ? null : dataGlobalRetention.maxRetention());
216219
out.writeOptionalTimeValue(failureGlobalRetention == null ? null : failureGlobalRetention.defaultRetention());

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import org.apache.lucene.search.ScoreDoc;
1515
import org.apache.lucene.search.TopFieldDocs;
1616
import org.elasticsearch.ExceptionsHelper;
17-
import org.elasticsearch.TransportVersions;
17+
import org.elasticsearch.TransportVersion;
1818
import org.elasticsearch.Version;
1919
import org.elasticsearch.action.ActionListener;
2020
import org.elasticsearch.action.IndicesRequest;
@@ -82,6 +82,8 @@ public class SearchQueryThenFetchAsyncAction extends AbstractSearchAsyncAction<S
8282

8383
private static final Logger logger = LogManager.getLogger(SearchQueryThenFetchAsyncAction.class);
8484

85+
private static final TransportVersion BATCHED_QUERY_PHASE_VERSION = TransportVersion.fromName("batched_query_phase_version");
86+
8587
private final SearchProgressListener progressListener;
8688

8789
// informations to track the best bottom top doc globally.
@@ -476,7 +478,7 @@ protected void doRun(Map<SearchShardIterator, Integer> shardIndexMap) {
476478
return;
477479
}
478480
// must check both node and transport versions to correctly deal with BwC on proxy connections
479-
if (connection.getTransportVersion().before(TransportVersions.BATCHED_QUERY_PHASE_VERSION)
481+
if (connection.getTransportVersion().supports(BATCHED_QUERY_PHASE_VERSION) == false
480482
|| connection.getNode().getVersionInformation().nodeVersion().before(Version.V_9_1_0)) {
481483
executeWithoutBatching(routing, request);
482484
return;

‎server/src/main/java/org/elasticsearch/action/support/IndexComponentSelector.java‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
package org.elasticsearch.action.support;
1111

1212
import org.elasticsearch.TransportVersion;
13-
import org.elasticsearch.TransportVersions;
1413
import org.elasticsearch.common.io.stream.StreamInput;
1514
import org.elasticsearch.common.io.stream.StreamOutput;
1615
import org.elasticsearch.common.io.stream.Writeable;
@@ -95,9 +94,7 @@ public static IndexComponentSelector getByKeyOrThrow(@Nullable String key) {
9594

9695
public static IndexComponentSelector read(StreamInput in) throws IOException {
9796
byte id = in.readByte();
98-
if (in.getTransportVersion().supports(REMOVE_ALL_APPLICABLE_SELECTOR)
99-
|| in.getTransportVersion().isPatchFrom(TransportVersions.REMOVE_ALL_APPLICABLE_SELECTOR_BACKPORT_8_18)
100-
|| in.getTransportVersion().isPatchFrom(TransportVersions.REMOVE_ALL_APPLICABLE_SELECTOR_BACKPORT_8_19)) {
97+
if (in.getTransportVersion().supports(REMOVE_ALL_APPLICABLE_SELECTOR)) {
10198
return getById(id);
10299
} else {
103100
// Legacy value ::*, converted to ::data

‎server/src/main/java/org/elasticsearch/cluster/metadata/DataStreamFailureStore.java‎

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

1010
package org.elasticsearch.cluster.metadata;
1111

12-
import org.elasticsearch.TransportVersions;
12+
import org.elasticsearch.TransportVersion;
1313
import org.elasticsearch.cluster.Diff;
1414
import org.elasticsearch.cluster.SimpleDiffable;
1515
import org.elasticsearch.common.Strings;
@@ -59,6 +59,8 @@ public record DataStreamFailureStore(@Nullable Boolean enabled, @Nullable DataSt
5959
);
6060
}
6161

62+
private static final TransportVersion INTRODUCE_FAILURES_LIFECYCLE = TransportVersion.fromName("introduce_failures_lifecycle");
63+
6264
/**
6365
* @param enabled, true when the failure is enabled, false when it's disabled, null when it depends on other configuration. Currently,
6466
* null value is not supported because there are no other arguments
@@ -74,10 +76,7 @@ public record DataStreamFailureStore(@Nullable Boolean enabled, @Nullable DataSt
7476
public DataStreamFailureStore(StreamInput in) throws IOException {
7577
this(
7678
in.readOptionalBoolean(),
77-
in.getTransportVersion().onOrAfter(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE)
78-
|| in.getTransportVersion().isPatchFrom(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE_BACKPORT_8_19)
79-
? in.readOptionalWriteable(DataStreamLifecycle::new)
80-
: null
79+
in.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE) ? in.readOptionalWriteable(DataStreamLifecycle::new) : null
8180
);
8281
}
8382

@@ -88,8 +87,7 @@ public static Diff<DataStreamFailureStore> readDiffFrom(StreamInput in) throws I
8887
@Override
8988
public void writeTo(StreamOutput out) throws IOException {
9089
out.writeOptionalBoolean(enabled);
91-
if (out.getTransportVersion().onOrAfter(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE)
92-
|| out.getTransportVersion().isPatchFrom(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE_BACKPORT_8_19)) {
90+
if (out.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE)) {
9391
out.writeOptionalWriteable(lifecycle);
9492
}
9593
}
@@ -169,17 +167,15 @@ public Template(@Nullable Boolean enabled, @Nullable DataStreamLifecycle.Templat
169167
@Override
170168
public void writeTo(StreamOutput out) throws IOException {
171169
ResettableValue.write(out, enabled, StreamOutput::writeBoolean);
172-
if (out.getTransportVersion().onOrAfter(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE)
173-
|| out.getTransportVersion().isPatchFrom(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE_BACKPORT_8_19)) {
170+
if (out.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE)) {
174171
ResettableValue.write(out, lifecycle, (o, v) -> v.writeTo(o));
175172
}
176173
}
177174

178175
public static Template read(StreamInput in) throws IOException {
179176
ResettableValue<Boolean> enabled = ResettableValue.read(in, StreamInput::readBoolean);
180177
ResettableValue<DataStreamLifecycle.Template> lifecycle = ResettableValue.undefined();
181-
if (in.getTransportVersion().onOrAfter(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE)
182-
|| in.getTransportVersion().isPatchFrom(TransportVersions.INTRODUCE_FAILURES_LIFECYCLE_BACKPORT_8_19)) {
178+
if (in.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE)) {
183179
lifecycle = ResettableValue.read(in, DataStreamLifecycle.Template::read);
184180
}
185181
return new Template(enabled, lifecycle);

0 commit comments

Comments
 (0)