File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
server/src/main/java/org/elasticsearch
x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -177,6 +177,7 @@ static TransportVersion def(int id) {
177177 public static final TransportVersion ESQL_DRIVER_TASK_DESCRIPTION_8_19 = def (8_841_0_30 );
178178 public static final TransportVersion ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED_8_19 = def (8_841_0_31 );
179179 public static final TransportVersion V_8_19_FIELD_CAPS_ADD_CLUSTER_ALIAS = def (8_841_0_32 );
180+ public static final TransportVersion ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME_8_19 = def (8_841_0_34 );
180181 public static final TransportVersion V_9_0_0 = def (9_000_0_09 );
181182 public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_1 = def (9_000_0_10 );
182183 public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_2 = def (9_000_0_11 );
Original file line number Diff line number Diff line change @@ -359,7 +359,8 @@ protected Status(StreamInput in) throws IOException {
359359 rowsReceived = 0 ;
360360 rowsEmitted = 0 ;
361361 }
362- if (in .getTransportVersion ().onOrAfter (TransportVersions .ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME )) {
362+ if (in .getTransportVersion ().onOrAfter (TransportVersions .ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME )
363+ || in .getTransportVersion ().isPatchFrom (TransportVersions .ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME_8_19 )) {
363364 emitNanos = in .readVLong ();
364365 } else {
365366 emitNanos = 0 ;
@@ -376,7 +377,8 @@ public void writeTo(StreamOutput out) throws IOException {
376377 out .writeVLong (rowsReceived );
377378 out .writeVLong (rowsEmitted );
378379 }
379- if (out .getTransportVersion ().onOrAfter (TransportVersions .ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME )) {
380+ if (out .getTransportVersion ().onOrAfter (TransportVersions .ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME )
381+ || out .getTransportVersion ().isPatchFrom (TransportVersions .ESQL_HASH_OPERATOR_STATUS_OUTPUT_TIME_8_19 )) {
380382 out .writeVLong (emitNanos );
381383 }
382384 }
You can’t perform that action at this time.
0 commit comments