diff --git a/src/main/java/org/elasticsearch/action/bulk/BulkItemRequest.java b/src/main/java/org/elasticsearch/action/bulk/BulkItemRequest.java index 4ce9da3b4a3..9a832d0ac51 100644 --- a/src/main/java/org/elasticsearch/action/bulk/BulkItemRequest.java +++ b/src/main/java/org/elasticsearch/action/bulk/BulkItemRequest.java @@ -102,7 +102,7 @@ public class BulkItemRequest implements Streamable { request = new UpdateRequest(); } request.readFrom(in); - if (in.getVersion().onOrAfter(Version.V_1_4_0_Beta1)) { + if (in.getVersion().onOrAfter(Version.V_1_3_3)) { if (in.readBoolean()) { primaryResponse = BulkItemResponse.readBulkItem(in); } @@ -121,7 +121,7 @@ public class BulkItemRequest implements Streamable { out.writeByte((byte) 2); } request.writeTo(out); - if (out.getVersion().onOrAfter(Version.V_1_4_0_Beta1)) { + if (out.getVersion().onOrAfter(Version.V_1_3_3)) { out.writeOptionalStreamable(primaryResponse); out.writeBoolean(ignoreOnReplica); } diff --git a/src/main/java/org/elasticsearch/action/bulk/BulkShardRequest.java b/src/main/java/org/elasticsearch/action/bulk/BulkShardRequest.java index 35ab9946904..ddfc300c1ed 100644 --- a/src/main/java/org/elasticsearch/action/bulk/BulkShardRequest.java +++ b/src/main/java/org/elasticsearch/action/bulk/BulkShardRequest.java @@ -95,9 +95,9 @@ public class BulkShardRequest extends ShardReplicationOperationRequest