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 @@ -238,8 +238,7 @@ static TransportVersion def(int id) {
238
238
public static final TransportVersion ESQL_QUERY_PLANNING_DURATION_8_19 = def (8_841_0_45 );
239
239
public static final TransportVersion SEARCH_SOURCE_EXCLUDE_VECTORS_PARAM_8_19 = def (8_841_0_46 );
240
240
public static final TransportVersion ML_INFERENCE_MISTRAL_CHAT_COMPLETION_ADDED_8_19 = def (8_841_0_47 );
241
- public static final TransportVersion SETTINGS_IN_DATA_STREAMS = def (8_841_0_48 ); // TODO NO NO NO NO NO, also rename this
242
- public static final TransportVersion SETTINGS_IN_DATA_STREAMS_DRY_RUN = def (8_841_0_49 ); // TODO NO NO NO NO NO, also rename this
241
+ public static final TransportVersion SETTINGS_IN_DATA_STREAMS_8_19 = def (8_841_0_48 ); // TODO NO NO NO NO NO
243
242
244
243
/*
245
244
* STOP! READ THIS FIRST! No, really,
Original file line number Diff line number Diff line change 9
9
10
10
package org .elasticsearch .action .datastreams ;
11
11
12
- import org .elasticsearch .TransportVersions ;
13
12
import org .elasticsearch .action .ActionResponse ;
14
13
import org .elasticsearch .action .ActionType ;
15
14
import org .elasticsearch .action .IndicesRequest ;
@@ -83,21 +82,15 @@ public Request(StreamInput in) throws IOException {
83
82
super (in );
84
83
this .dataStreamNames = in .readStringArray ();
85
84
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 ();
91
86
}
92
87
93
88
@ Override
94
89
public void writeTo (StreamOutput out ) throws IOException {
95
90
super .writeTo (out );
96
91
out .writeStringArray (dataStreamNames );
97
92
settings .writeTo (out );
98
- if (out .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS_DRY_RUN )) {
99
- out .writeBoolean (dryRun );
100
- }
93
+ out .writeBoolean (dryRun );
101
94
}
102
95
103
96
@ Override
Original file line number Diff line number Diff line change @@ -272,7 +272,7 @@ public static DataStream read(StreamInput in) throws IOException {
272
272
dataStreamOptions = failureStoreEnabled ? DataStreamOptions .FAILURE_STORE_ENABLED : null ;
273
273
}
274
274
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 )) {
276
276
settings = Settings .readSettingsFromStream (in );
277
277
} else {
278
278
settings = Settings .EMPTY ;
@@ -1320,7 +1320,7 @@ public void writeTo(StreamOutput out) throws IOException {
1320
1320
if (out .getTransportVersion ().onOrAfter (DataStream .ADD_DATA_STREAM_OPTIONS_VERSION )) {
1321
1321
out .writeOptionalWriteable (dataStreamOptions .isEmpty () ? null : dataStreamOptions );
1322
1322
}
1323
- if (out .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS )) {
1323
+ if (out .getTransportVersion ().onOrAfter (TransportVersions .SETTINGS_IN_DATA_STREAMS_8_19 )) {
1324
1324
settings .writeTo (out );
1325
1325
}
1326
1326
}
You can’t perform that action at this time.
0 commit comments