Skip to content

Commit 1f2476c

Browse files
added filter for vector lengths
1 parent 1039322 commit 1f2476c

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

posting/index.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -234,12 +234,12 @@ func (mp *MutationPipeline) InsertTokenizerIndexes(ctx context.Context, pipeline
234234
mp.txn.cache.Lock()
235235
defer mp.txn.cache.Unlock()
236236

237-
if info.hasUpsert {
238-
globalMapI.Iterate(func(key string, value *pb.PostingList) error {
239-
mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
240-
return nil
241-
})
242-
}
237+
// if info.hasUpsert {
238+
// globalMapI.Iterate(func(key string, value *pb.PostingList) error {
239+
// mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
240+
// return nil
241+
// })
242+
// }
243243

244244
globalMap := mp.txn.cache.deltas.GetIndexMapForPredicate(pipeline.attr)
245245
if globalMap == nil {

0 commit comments

Comments
 (0)