Skip to content

Commit 802ec4c

Browse files
committed
Fix for the breakage in the previous commit. Reset MapEntry after getting from pool.
1 parent 800b443 commit 802ec4c

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

dgraph/cmd/bulk/mapper.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ func (m *mapper) addMapEntry(key []byte, p *pb.Posting, shard int) {
190190
atomic.AddInt64(&m.prog.mapEdgeCount, 1)
191191

192192
me := m.mePool.Get().(*pb.MapEntry)
193-
me.Key = key
193+
*me = pb.MapEntry{Key: key}
194194

195195
if p.PostingType != pb.Posting_REF || len(p.Facets) > 0 {
196196
me.Posting = p

0 commit comments

Comments
 (0)