File tree Expand file tree Collapse file tree 3 files changed +11
-6
lines changed
server/src/main/java/org/elasticsearch
compute/src/main/java/org/elasticsearch/compute/operator
src/main/java/org/elasticsearch/xpack/esql/action Expand file tree Collapse file tree 3 files changed +11
-6
lines changed Original file line number Diff line number Diff line change @@ -209,6 +209,7 @@ static TransportVersion def(int id) {
209209 public static final TransportVersion ML_INFERENCE_ELASTIC_DENSE_TEXT_EMBEDDINGS_ADDED_8_19 = def (8_841_0_59 );
210210 public static final TransportVersion ML_INFERENCE_COHERE_API_VERSION_8_19 = def (8_841_0_60 );
211211 public static final TransportVersion ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED_8_19 = def (8_841_0_61 );
212+ public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN_8_19 = def (8_841_0_62 );
212213 public static final TransportVersion V_9_0_0 = def (9_000_0_09 );
213214 public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_1 = def (9_000_0_10 );
214215 public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_2 = def (9_000_0_11 );
Original file line number Diff line number Diff line change @@ -95,8 +95,9 @@ public static DriverCompletionInfo readFrom(StreamInput in) throws IOException {
9595 in .readVLong (),
9696 in .readCollectionAsImmutableList (DriverProfile ::readFrom ),
9797 in .getTransportVersion ().onOrAfter (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN )
98- ? in .readCollectionAsImmutableList (PlanProfile ::readFrom )
99- : List .of ()
98+ || in .getTransportVersion ().isPatchFrom (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN_8_19 )
99+ ? in .readCollectionAsImmutableList (PlanProfile ::readFrom )
100+ : List .of ()
100101 );
101102 }
102103
@@ -105,7 +106,8 @@ public void writeTo(StreamOutput out) throws IOException {
105106 out .writeVLong (documentsFound );
106107 out .writeVLong (valuesLoaded );
107108 out .writeCollection (driverProfiles );
108- if (out .getTransportVersion ().onOrAfter (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN )) {
109+ if (out .getTransportVersion ().onOrAfter (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN )
110+ || out .getTransportVersion ().isPatchFrom (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN_8_19 )) {
109111 out .writeCollection (planProfiles );
110112 }
111113 }
Original file line number Diff line number Diff line change @@ -402,15 +402,17 @@ public static Profile readFrom(StreamInput in) throws IOException {
402402 return new Profile (
403403 in .readCollectionAsImmutableList (DriverProfile ::readFrom ),
404404 in .getTransportVersion ().onOrAfter (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN )
405- ? in .readCollectionAsImmutableList (PlanProfile ::readFrom )
406- : List .of ()
405+ || in .getTransportVersion ().isPatchFrom (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN_8_19 )
406+ ? in .readCollectionAsImmutableList (PlanProfile ::readFrom )
407+ : List .of ()
407408 );
408409 }
409410
410411 @ Override
411412 public void writeTo (StreamOutput out ) throws IOException {
412413 out .writeCollection (drivers );
413- if (out .getTransportVersion ().onOrAfter (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN )) {
414+ if (out .getTransportVersion ().onOrAfter (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN )
415+ || out .getTransportVersion ().isPatchFrom (TransportVersions .ESQL_PROFILE_INCLUDE_PLAN_8_19 )) {
414416 out .writeCollection (plans );
415417 }
416418 }
You can’t perform that action at this time.
0 commit comments