added filter for vector lengths

Author: darkcoderrises

posting/index.go

@@ -466,10 +466,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{}{}
 	}
@@ -675,9 +675,10 @@ func (mp *MutationPipeline) ProcessSingle(ctx context.Context, pipeline *Predica
 		binary.BigEndian.PutUint64(dataKey[len(dataKey)-8:], uid)
 		key := baseKey + string(dataKey[len(dataKey)-8:])
 
-		// if !info.noConflict {
-		// 	mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
-		// }
+		if !info.noConflict {
+			fmt.Println("Creating token", farm.Fingerprint64([]byte(key)), uid, pipeline.attr)
+			mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
+		}
 
 		if _, err := mp.txn.AddDelta(key, *pl); err != nil {
 			return err