diff --git a/plugin/pkg/scheduler/algorithm/predicates/predicates.go b/plugin/pkg/scheduler/algorithm/predicates/predicates.go index a5c63f4a7c5..60a412c7c00 100644 --- a/plugin/pkg/scheduler/algorithm/predicates/predicates.go +++ b/plugin/pkg/scheduler/algorithm/predicates/predicates.go @@ -18,6 +18,9 @@ package predicates import ( "fmt" + "math/rand" + "strconv" + "time" "github.com/golang/glog" "k8s.io/kubernetes/pkg/api" @@ -156,7 +159,13 @@ func (c *MaxPDVolumeCountChecker) filterVolumes(volumes []api.Volume, namespace } pvc, err := c.pvcInfo.GetPersistentVolumeClaimInfo(namespace, pvcName) if err != nil { - return err + // if the PVC is not found, log the error and count the PV towards the PV limit + // generate a random volume ID since its required for de-dup + glog.Error(err) + source := rand.NewSource(time.Now().UnixNano()) + generatedID := "missingPVC" + strconv.Itoa(rand.New(source).Intn(1000000)) + filteredVolumes[generatedID] = true + return nil } pvName := pvc.Spec.VolumeName @@ -166,7 +175,14 @@ func (c *MaxPDVolumeCountChecker) filterVolumes(volumes []api.Volume, namespace pv, err := c.pvInfo.GetPersistentVolumeInfo(pvName) if err != nil { - return err + // if the PV is not found, log the error + // and count the PV towards the PV limit + // generate a random volume ID since its required for de-dup + glog.Error(err) + source := rand.NewSource(time.Now().UnixNano()) + generatedID := "missingPV" + strconv.Itoa(rand.New(source).Intn(1000000)) + filteredVolumes[generatedID] = true + return nil } if id, ok := c.filter.FilterPersistentVolume(pv); ok { diff --git a/plugin/pkg/scheduler/algorithm/predicates/predicates_test.go b/plugin/pkg/scheduler/algorithm/predicates/predicates_test.go index 1221b663a85..cd1a4679bd3 100644 --- a/plugin/pkg/scheduler/algorithm/predicates/predicates_test.go +++ b/plugin/pkg/scheduler/algorithm/predicates/predicates_test.go @@ -1392,6 +1392,32 @@ func TestEBSVolumeCountConflicts(t *testing.T) { }, }, } + deletedPVCPod := &api.Pod{ + Spec: api.PodSpec{ + Volumes: []api.Volume{ + { + VolumeSource: api.VolumeSource{ + PersistentVolumeClaim: &api.PersistentVolumeClaimVolumeSource{ + ClaimName: "deletedPVC", + }, + }, + }, + }, + }, + } + deletedPVPod := &api.Pod{ + Spec: api.PodSpec{ + Volumes: []api.Volume{ + { + VolumeSource: api.VolumeSource{ + PersistentVolumeClaim: &api.PersistentVolumeClaimVolumeSource{ + ClaimName: "deletedPV", + }, + }, + }, + }, + }, + } emptyPod := &api.Pod{ Spec: api.PodSpec{}, } @@ -1466,6 +1492,34 @@ func TestEBSVolumeCountConflicts(t *testing.T) { fits: true, test: "the same EBS volumes are not counted multiple times", }, + { + newPod: ebsPVCPod, + existingPods: []*api.Pod{oneVolPod, deletedPVCPod}, + maxVols: 2, + fits: false, + test: "pod with missing PVC is counted towards the PV limit", + }, + { + newPod: ebsPVCPod, + existingPods: []*api.Pod{oneVolPod, deletedPVCPod}, + maxVols: 3, + fits: true, + test: "pod with missing PVC is counted towards the PV limit", + }, + { + newPod: ebsPVCPod, + existingPods: []*api.Pod{oneVolPod, deletedPVPod}, + maxVols: 2, + fits: false, + test: "pod with missing PV is counted towards the PV limit", + }, + { + newPod: ebsPVCPod, + existingPods: []*api.Pod{oneVolPod, deletedPVPod}, + maxVols: 3, + fits: true, + test: "pod with missing PV is counted towards the PV limit", + }, } pvInfo := FakePersistentVolumeInfo{ @@ -1473,7 +1527,7 @@ func TestEBSVolumeCountConflicts(t *testing.T) { ObjectMeta: api.ObjectMeta{Name: "someEBSVol"}, Spec: api.PersistentVolumeSpec{ PersistentVolumeSource: api.PersistentVolumeSource{ - AWSElasticBlockStore: &api.AWSElasticBlockStoreVolumeSource{}, + AWSElasticBlockStore: &api.AWSElasticBlockStoreVolumeSource{VolumeID: "ebsVol"}, }, }, }, @@ -1494,6 +1548,10 @@ func TestEBSVolumeCountConflicts(t *testing.T) { ObjectMeta: api.ObjectMeta{Name: "someNonEBSVol"}, Spec: api.PersistentVolumeClaimSpec{VolumeName: "someNonEBSVol"}, }, + { + ObjectMeta: api.ObjectMeta{Name: "deletedPV"}, + Spec: api.PersistentVolumeClaimSpec{VolumeName: "deletedPV"}, + }, } filter := VolumeFilter{