added filter for vector lengths

Author: darkcoderrises

posting/index.go

@@ -234,12 +234,12 @@ func (mp *MutationPipeline) InsertTokenizerIndexes(ctx context.Context, pipeline
 	mp.txn.cache.Lock()
 	defer mp.txn.cache.Unlock()
 
-	// if info.hasUpsert {
-	// 	globalMapI.Iterate(func(key string, value *pb.PostingList) error {
-	// 		mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
-	// 		return nil
-	// 	})
-	// }
+	if info.hasUpsert {
+		globalMapI.Iterate(func(key string, value *pb.PostingList) error {
+			mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
+			return nil
+		})
+	}
 
 	globalMap := mp.txn.cache.deltas.GetIndexMapForPredicate(pipeline.attr)
 	if globalMap == nil {
@@ -458,10 +458,10 @@ func (txn *Txn) addConflictKeyWithUid(key []byte, pl *pb.PostingList, hasUpsert
 		txn.conflicts = make(map[uint64]struct{})
 	}
 	keyHash := farm.Fingerprint64(key)
-	if hasUpsert {
-		txn.conflicts[keyHash] = struct{}{}
-		return
-	}
+	// if hasUpsert {
+	// 	txn.conflicts[keyHash] = struct{}{}
+	// 	return
+	// }
 	for _, post := range pl.Postings {
 		txn.conflicts[keyHash^post.Uid] = struct{}{}
 	}