Slated for inclusion in 6.1

DaveCTurner · Oct 11, 2017 · f004119 · f004119
1 parent d825792
commit f004119
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/org/elasticsearch/discovery/DiscoveryStats.java b/core/src/main/java/org/elasticsearch/discovery/DiscoveryStats.java
@@ -47,7 +47,7 @@ public DiscoveryStats(PendingClusterStateStats queueStats, PublishClusterStateSt
     public DiscoveryStats(StreamInput in) throws IOException {
         queueStats = in.readOptionalWriteable(PendingClusterStateStats::new);
 
-        if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+        if (in.getVersion().onOrAfter(Version.V_6_1_0)) {
             publishStats = in.readOptionalWriteable(PublishClusterStateStats::new);
         } else {
             publishStats = null;
@@ -58,7 +58,7 @@ public DiscoveryStats(StreamInput in) throws IOException {
     public void writeTo(StreamOutput out) throws IOException {
         out.writeOptionalWriteable(queueStats);
 
-        if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+        if (out.getVersion().onOrAfter(Version.V_6_1_0)) {
             out.writeOptionalWriteable(publishStats);
         }
     }