diff --git a/datanode/space_manager.go b/datanode/space_manager.go index b4ecf751d..b4c069b30 100644 --- a/datanode/space_manager.go +++ b/datanode/space_manager.go @@ -681,9 +681,11 @@ func (manager *SpaceManager) CreatePartition(request *proto.CreateDataPartitionR }() if dp, err = CreateDataPartition(dpCfg, disk, request); err != nil { - manager.partitionMutex.Lock() - delete(manager.partitions, dp.partitionID) - manager.partitionMutex.Unlock() + if dp != nil { + manager.partitionMutex.Lock() + delete(manager.partitions, dp.partitionID) + manager.partitionMutex.Unlock() + } return } return