diff --git a/core/src/main/java/org/apache/lucene/search/grouping/CollapseTopFieldDocs.java b/core/src/main/java/org/apache/lucene/search/grouping/CollapseTopFieldDocs.java
index b4d3c823439..c5362cbf858 100644
--- a/core/src/main/java/org/apache/lucene/search/grouping/CollapseTopFieldDocs.java
+++ b/core/src/main/java/org/apache/lucene/search/grouping/CollapseTopFieldDocs.java
@@ -40,7 +40,7 @@ public final class CollapseTopFieldDocs extends TopFieldDocs {
     /** The collapse value for each top doc */
     public final Object[] collapseValues;
 
-    public CollapseTopFieldDocs(String field, int totalHits, ScoreDoc[] scoreDocs,
+    public CollapseTopFieldDocs(String field, long totalHits, ScoreDoc[] scoreDocs,
                                 SortField[] sortFields, Object[] values, float maxScore) {
         super(totalHits, scoreDocs, sortFields, maxScore);
         this.field = field;
@@ -170,7 +170,7 @@ public final class CollapseTopFieldDocs extends TopFieldDocs {
         }
         final PriorityQueue<ShardRef> queue = new MergeSortQueue(sort, shardHits);
 
-        int totalHitCount = 0;
+        long totalHitCount = 0;
         int availHitCount = 0;
         float maxScore = Float.MIN_VALUE;
         for(int shardIDX=0;shardIDX<shardHits.length;shardIDX++) {
diff --git a/core/src/main/java/org/elasticsearch/common/lucene/Lucene.java b/core/src/main/java/org/elasticsearch/common/lucene/Lucene.java
index 10adf530b1e..b156c9bb296 100644
--- a/core/src/main/java/org/elasticsearch/common/lucene/Lucene.java
+++ b/core/src/main/java/org/elasticsearch/common/lucene/Lucene.java
@@ -295,7 +295,7 @@ public class Lucene {
             }
             return new TopFieldDocs(totalHits, fieldDocs, fields, maxScore);
         } else if (type == 2) {
-            int totalHits = in.readVInt();
+            long totalHits = in.readVLong();
             float maxScore = in.readFloat();
 
             String field = in.readString();