added filter for vector lengths

Author: darkcoderrises

posting/mvcc.go

@@ -125,14 +125,18 @@ func (ir *incrRollupi) rollUpKey(writer *TxnWriter, key []byte) error {
 		return err
 	}
 
-	pl := &pb.PostingList{}
-	if err := proto.Unmarshal(kvs[0].Value, pl); err != nil {
-		return err
-	}
-	newLength := codec.ExactLen(pl.Pack)
-	if newLength != length {
-		fmt.Println(l.Print())
-		panic(errors.Errorf("New length %d does not match old length %d", newLength, length))
+	pk, _ := x.Parse(key)
+
+	if pk.IsData() {
+		pl := &pb.PostingList{}
+		if err := proto.Unmarshal(kvs[0].Value, pl); err != nil {
+			return err
+		}
+		newLength := codec.ExactLen(pl.Pack)
+		if newLength != length {
+			fmt.Println(l.Print())
+			panic(errors.Errorf("New length %d does not match old length %d", newLength, length))
+		}
 	}
 
 	RemoveCacheFor(key)