Skip to content

Commit 2f49a5e

Browse files
authored
Migrate transport version 9112_000 (#134579)
ES-12334
1 parent 85cc749 commit 2f49a5e

File tree

3 files changed

+5
-3
lines changed

3 files changed

+5
-3
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -321,7 +321,6 @@ static TransportVersion def(int id) {
321321
public static final TransportVersion ML_INFERENCE_ELASTIC_DENSE_TEXT_EMBEDDINGS_ADDED = def(9_109_00_0);
322322
public static final TransportVersion ML_INFERENCE_COHERE_API_VERSION = def(9_110_0_00);
323323
public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN = def(9_111_0_00);
324-
public static final TransportVersion MAPPINGS_IN_DATA_STREAMS = def(9_112_0_00);
325324
public static final TransportVersion INFERENCE_API_EIS_DIAGNOSTICS = def(9_156_0_00);
326325
public static final TransportVersion ML_INFERENCE_ENDPOINT_CACHE = def(9_157_0_00);
327326
public static final TransportVersion INDEX_SOURCE = def(9_158_0_00);

server/src/main/java/org/elasticsearch/cluster/metadata/DataStream.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,8 @@ public final class DataStream implements SimpleDiffable<DataStream>, ToXContentO
8787

8888
private static final Logger LOGGER = LogManager.getLogger(DataStream.class);
8989

90+
private static final TransportVersion MAPPINGS_IN_DATA_STREAMS = TransportVersion.fromName("mappings_in_data_streams");
91+
9092
public static final NodeFeature DATA_STREAM_FAILURE_STORE_FEATURE = new NodeFeature("data_stream.failure_store");
9193
public static final boolean LOGS_STREAM_FEATURE_FLAG = new FeatureFlag("logs_stream").isEnabled();
9294
public static final TransportVersion ADDED_FAILURE_STORE_TRANSPORT_VERSION = TransportVersions.V_8_12_0;
@@ -341,7 +343,7 @@ public static DataStream read(StreamInput in) throws IOException {
341343
settings = Settings.EMPTY;
342344
}
343345
CompressedXContent mappings;
344-
if (in.getTransportVersion().onOrAfter(TransportVersions.MAPPINGS_IN_DATA_STREAMS)) {
346+
if (in.getTransportVersion().supports(MAPPINGS_IN_DATA_STREAMS)) {
345347
mappings = CompressedXContent.readCompressedString(in);
346348
} else {
347349
mappings = EMPTY_MAPPINGS;
@@ -1483,7 +1485,7 @@ public void writeTo(StreamOutput out) throws IOException {
14831485
|| out.getTransportVersion().isPatchFrom(TransportVersions.SETTINGS_IN_DATA_STREAMS_8_19)) {
14841486
settings.writeTo(out);
14851487
}
1486-
if (out.getTransportVersion().onOrAfter(TransportVersions.MAPPINGS_IN_DATA_STREAMS)) {
1488+
if (out.getTransportVersion().supports(MAPPINGS_IN_DATA_STREAMS)) {
14871489
mappings.writeTo(out);
14881490
}
14891491
}
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9112000

0 commit comments

Comments
 (0)