Fix for the breakage in the previous commit. Reset MapEntry after get…

…ting from pool.
hypermodeinc · Aug 7, 2019 · 802ec4c · 802ec4c
1 parent 800b443
commit 802ec4c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dgraph/cmd/bulk/mapper.go b/dgraph/cmd/bulk/mapper.go
@@ -190,7 +190,7 @@ func (m *mapper) addMapEntry(key []byte, p *pb.Posting, shard int) {
 	atomic.AddInt64(&m.prog.mapEdgeCount, 1)
 
 	me := m.mePool.Get().(*pb.MapEntry)
-	me.Key = key
+	*me = pb.MapEntry{Key: key}
 
 	if p.PostingType != pb.Posting_REF || len(p.Facets) > 0 {
 		me.Posting = p