diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/action/PutFollowAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/action/PutFollowAction.java index 6ca91bd7f0d..13ec8b84f81 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/action/PutFollowAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/action/PutFollowAction.java @@ -202,8 +202,7 @@ public final class PutFollowAction extends Action { super(in); remoteCluster = in.readString(); leaderIndex = in.readString(); - // TODO: Update after backport - if (in.getVersion().onOrAfter(Version.V_7_0_0)) { + if (in.getVersion().onOrAfter(Version.V_6_7_0)) { waitForActiveShards(ActiveShardCount.readFrom(in)); } followRequest = new ResumeFollowAction.Request(in); @@ -214,8 +213,7 @@ public final class PutFollowAction extends Action { super.writeTo(out); out.writeString(remoteCluster); out.writeString(leaderIndex); - // TODO: Update after backport - if (out.getVersion().onOrAfter(Version.V_7_0_0)) { + if (out.getVersion().onOrAfter(Version.V_6_7_0)) { waitForActiveShards.writeTo(out); } followRequest.writeTo(out);