@@ -79,7 +79,7 @@ public record DataStreamFailureStore(@Nullable Boolean enabled, @Nullable DataSt
7979 public DataStreamFailureStore (StreamInput in ) throws IOException {
8080 this (
8181 in .readOptionalBoolean (),
82- in .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURE_LIFECYCLE )
82+ in .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURES_LIFECYCLE )
8383 ? in .readOptionalWriteable (DataStreamLifecycle ::new )
8484 : null
8585 );
@@ -92,7 +92,7 @@ public static Diff<DataStreamFailureStore> readDiffFrom(StreamInput in) throws I
9292 @ Override
9393 public void writeTo (StreamOutput out ) throws IOException {
9494 out .writeOptionalBoolean (enabled );
95- if (out .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURE_LIFECYCLE )) {
95+ if (out .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURES_LIFECYCLE )) {
9696 out .writeOptionalWriteable (lifecycle );
9797 }
9898 }
@@ -173,15 +173,15 @@ public Template(@Nullable Boolean enabled, @Nullable DataStreamLifecycle.Templat
173173 @ Override
174174 public void writeTo (StreamOutput out ) throws IOException {
175175 ResettableValue .write (out , enabled , StreamOutput ::writeBoolean );
176- if (out .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURE_LIFECYCLE )) {
176+ if (out .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURES_LIFECYCLE )) {
177177 ResettableValue .write (out , lifecycle , (o , v ) -> v .writeTo (o ));
178178 }
179179 }
180180
181181 public static Template read (StreamInput in ) throws IOException {
182182 ResettableValue <Boolean > enabled = ResettableValue .read (in , StreamInput ::readBoolean );
183183 ResettableValue <DataStreamLifecycle .Template > lifecycle = ResettableValue .undefined ();
184- if (in .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURE_LIFECYCLE )) {
184+ if (in .getTransportVersion ().onOrAfter (TransportVersions .INTRODUCE_FAILURES_LIFECYCLE )) {
185185 lifecycle = ResettableValue .read (in , DataStreamLifecycle .Template ::read );
186186 }
187187 return new Template (enabled , lifecycle );
0 commit comments