diff --git a/core/etcd.go b/core/etcd.go index 406181580..476d30e41 100644 --- a/core/etcd.go +++ b/core/etcd.go @@ -124,11 +124,14 @@ func (self *TopologyMapper) MakeFragments(db string, slice_int int) error { for _, dbs := range self.service.Cluster.GetDatabases() { for _, fsi := range dbs.GetFrameSliceIntersects() { fragment := fsi.GetFragment() - process := fragment.GetProcess().Id().String() - if len(process) > 1 { - i := m[process] - i++ - m[process] = i + p := fragment.GetProcess() + if p != nil { + process := p.Id().String() + if len(process) > 1 { + i := m[process] + i++ + m[process] = i + } } } }