CreationTimestamp field introduced to JobInfo

Author: adam-marek

pkg/scheduler/api/job_info.go

@@ -18,7 +18,7 @@ package api
 
 import (
 	"fmt"
-
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/api/core/v1"
 	policyv1 "k8s.io/api/policy/v1beta1"
 	"k8s.io/apimachinery/pkg/types"
@@ -128,6 +128,8 @@ type JobInfo struct {
 	Allocated    *Resource
 	TotalRequest *Resource
 
+	CreationTimestamp metav1.Time
+	
 	PodGroup *arbcorev1.PodGroup
 
 	// TODO(k82cn): keep backward compatbility, removed it when v1alpha1 finalized.
@@ -164,6 +166,7 @@ func (ji *JobInfo) SetPodGroup(pg *arbcorev1.PodGroup) {
 		ji.Queue = QueueID(pg.Spec.Queue)
 	}
 
+	ji.CreationTimestamp = pg.GetCreationTimestamp()
 	ji.PodGroup = pg
 }
 
@@ -173,6 +176,7 @@ func (ji *JobInfo) SetPDB(pdb *policyv1.PodDisruptionBudget) {
 	ji.Namespace = pdb.Namespace
 	ji.Queue = QueueID(pdb.Namespace)
 
+	ji.CreationTimestamp = pdb.GetCreationTimestamp()
 	ji.PDB = pdb
 }
 
@@ -267,14 +271,16 @@ func (ji *JobInfo) Clone() *JobInfo {
 		NodeSelector: map[string]string{},
 		Allocated:    ji.Allocated.Clone(),
 		TotalRequest: ji.TotalRequest.Clone(),
-
+		
 		PDB:      ji.PDB,
 		PodGroup: ji.PodGroup,
-
+		
 		TaskStatusIndex: map[TaskStatus]tasksMap{},
 		Tasks:           tasksMap{},
 	}
 
+	ji.CreationTimestamp.DeepCopyInto(&info.CreationTimestamp)
+	
 	for k, v := range ji.NodeSelector {
 		info.NodeSelector[k] = v
 	}

pkg/scheduler/plugins/gang/gang.go

@@ -120,11 +120,11 @@ func (gp *gangPlugin) OnSessionOpen(ssn *framework.Session) {
 		}
 
 		if !lReady && !rReady {
-			if lv.PodGroup.GetCreationTimestamp().Time.Equal(rv.PodGroup.GetCreationTimestamp().Time) {
+			if lv.CreationTimestamp.Equal(&rv.CreationTimestamp) {
 				if lv.UID < rv.UID {
 					return -1;
 				}
-			} else if lv.PodGroup.GetCreationTimestamp().Time.Before(rv.PodGroup.GetCreationTimestamp().Time) {
+			} else if lv.CreationTimestamp.Before(&rv.CreationTimestamp) {
 				return -1
 			}
 			return 1