added filter for vector lengths

Author: darkcoderrises

posting/mvcc.go

@@ -9,7 +9,6 @@ import (
 	"bytes"
 	"context"
 	"encoding/hex"
-	"fmt"
 	"math"
 	"strconv"
 	"sync"
@@ -27,7 +26,6 @@ import (
 	"github.com/dgraph-io/dgo/v250/protos/api"
 	"github.com/dgraph-io/ristretto/v2"
 	"github.com/dgraph-io/ristretto/v2/z"
-	"github.com/hypermodeinc/dgraph/v25/codec"
 	"github.com/hypermodeinc/dgraph/v25/protos/pb"
 	"github.com/hypermodeinc/dgraph/v25/x"
 )
@@ -116,29 +114,11 @@ func (ir *incrRollupi) rollUpKey(writer *TxnWriter, key []byte) error {
 		return err
 	}
 
-	l.RLock()
-	length := l.GetLength(ts)
-	l.RUnlock()
-
 	kvs, err := l.Rollup(nil, ts)
 	if err != nil {
 		return err
 	}
 
-	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)
 	// TODO Update cache with rolled up results
 	// If we do a rollup, we typically won't need to update the key in cache.