diff --git a/dgraph/cmd/bulk/mapper.go b/dgraph/cmd/bulk/mapper.go index 0d822f290a8..fbcb3eb263d 100644 --- 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