Skip to content

Commit cfc1a30

Browse files
committed
fix supports
1 parent fe9188e commit cfc1a30

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/datastreams/DataStreamFeatureSetUsage.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -137,14 +137,14 @@ public DataStreamStats(StreamInput in) throws IOException {
137137
in.getTransportVersion().onOrAfter(TransportVersions.FAILURE_STORE_ENABLED_BY_CLUSTER_SETTING) ? in.readVLong() : 0,
138138
in.getTransportVersion().onOrAfter(TransportVersions.V_8_15_0) ? in.readVLong() : 0,
139139
in.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE) ? in.readVLong() : 0,
140-
in.getTransportVersion().onOrAfter(INTRODUCE_FAILURES_LIFECYCLE) ? in.readVLong() : 0,
141-
in.getTransportVersion().onOrAfter(INTRODUCE_FAILURES_LIFECYCLE)
140+
in.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE) ? in.readVLong() : 0,
141+
in.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE)
142142
? DataStreamLifecycleFeatureSetUsage.RetentionStats.read(in)
143143
: DataStreamLifecycleFeatureSetUsage.RetentionStats.NO_DATA,
144-
in.getTransportVersion().onOrAfter(INTRODUCE_FAILURES_LIFECYCLE)
144+
in.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE)
145145
? DataStreamLifecycleFeatureSetUsage.RetentionStats.read(in)
146146
: DataStreamLifecycleFeatureSetUsage.RetentionStats.NO_DATA,
147-
in.getTransportVersion().onOrAfter(INTRODUCE_FAILURES_LIFECYCLE)
147+
in.getTransportVersion().supports(INTRODUCE_FAILURES_LIFECYCLE)
148148
? in.readMap(DataStreamLifecycleFeatureSetUsage.GlobalRetentionStats::new)
149149
: Map.of()
150150
);

0 commit comments

Comments
 (0)