diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/deletebyquery/DeleteByQueryRequest.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/deletebyquery/DeleteByQueryRequest.java
index b52c6bbfda5..60868e2d8ef 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/deletebyquery/DeleteByQueryRequest.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/deletebyquery/DeleteByQueryRequest.java
@@ -293,6 +293,16 @@ public class DeleteByQueryRequest extends IndicesReplicationOperationRequest {
         if (in.readBoolean()) {
             routing = in.readUTF();
         }
+
+        int size = in.readVInt();
+        if (size == 0) {
+            types = Strings.EMPTY_ARRAY;
+        } else {
+            types = new String[size];
+            for (int i = 0; i < size; i++) {
+                types[i] = in.readUTF();
+            }
+        }
     }
 
     public void writeTo(StreamOutput out) throws IOException {
@@ -313,6 +323,11 @@ public class DeleteByQueryRequest extends IndicesReplicationOperationRequest {
             out.writeBoolean(true);
             out.writeUTF(routing);
         }
+
+        out.writeVInt(types.length);
+        for (String type : types) {
+            out.writeUTF(type);
+        }
     }
 
     @Override public String toString() {