File tree Expand file tree Collapse file tree 3 files changed +5
-13
lines changed
server/src/main/java/org/elasticsearch Expand file tree Collapse file tree 3 files changed +5
-13
lines changed Original file line number Diff line number Diff line change @@ -239,8 +239,7 @@ static TransportVersion def(int id) {
239239 public static final TransportVersion SEARCH_SOURCE_EXCLUDE_VECTORS_PARAM_8_19 = def (8_841_0_46 );
240240 public static final TransportVersion ML_INFERENCE_MISTRAL_CHAT_COMPLETION_ADDED_8_19 = def (8_841_0_47 );
241241 public static final TransportVersion ML_INFERENCE_ELASTIC_RERANK_ADDED_8_19 = def (8_841_0_48 );
242- public static final TransportVersion SETTINGS_IN_DATA_STREAMS = def (8_841_0_49 ); // TODO NO NO NO NO NO, also rename this
243- public static final TransportVersion SETTINGS_IN_DATA_STREAMS_DRY_RUN = def (8_841_0_50 ); // TODO NO NO NO NO NO, also rename this
242+ public static final TransportVersion SETTINGS_IN_DATA_STREAMS_8_19 = def (8_841_0_49 ); // TODO NO NO NO NO NO
244243
245244 /*
246245 * STOP! READ THIS FIRST! No, really,
Original file line number Diff line number Diff line change 99
1010package org .elasticsearch .action .datastreams ;
1111
12- import org .elasticsearch .TransportVersions ;
1312import org .elasticsearch .action .ActionResponse ;
1413import org .elasticsearch .action .ActionType ;
1514import org .elasticsearch .action .IndicesRequest ;
@@ -83,21 +82,15 @@ public Request(StreamInput in) throws IOException {
8382 super (in );
8483 this .dataStreamNames = in .readStringArray ();
8584 this .settings = Settings .readSettingsFromStream (in );
86- if (in .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS )) {
87- this .dryRun = in .readBoolean ();
88- } else {
89- this .dryRun = false ;
90- }
85+ this .dryRun = in .readBoolean ();
9186 }
9287
9388 @ Override
9489 public void writeTo (StreamOutput out ) throws IOException {
9590 super .writeTo (out );
9691 out .writeStringArray (dataStreamNames );
9792 settings .writeTo (out );
98- if (out .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS_DRY_RUN )) {
99- out .writeBoolean (dryRun );
100- }
93+ out .writeBoolean (dryRun );
10194 }
10295
10396 @ Override
Original file line number Diff line number Diff line change @@ -272,7 +272,7 @@ public static DataStream read(StreamInput in) throws IOException {
272272 dataStreamOptions = failureStoreEnabled ? DataStreamOptions .FAILURE_STORE_ENABLED : null ;
273273 }
274274 final Settings settings ;
275- if (in .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS )) {
275+ if (in .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS_8_19 )) {
276276 settings = Settings .readSettingsFromStream (in );
277277 } else {
278278 settings = Settings .EMPTY ;
@@ -1320,7 +1320,7 @@ public void writeTo(StreamOutput out) throws IOException {
13201320 if (out .getTransportVersion ().onOrAfter (DataStream .ADD_DATA_STREAM_OPTIONS_VERSION )) {
13211321 out .writeOptionalWriteable (dataStreamOptions .isEmpty () ? null : dataStreamOptions );
13221322 }
1323- if (out .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS )) {
1323+ if (out .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS_8_19 )) {
13241324 settings .writeTo (out );
13251325 }
13261326 }
You can’t perform that action at this time.
0 commit comments