From 5d38a5a7ce03e96cd2318752379a843678e1a1b5 Mon Sep 17 00:00:00 2001 From: "Da K. Ma" Date: Wed, 7 Nov 2018 13:00:00 +0800 Subject: [PATCH] Ordered Job by creation time. Signed-off-by: Da K. Ma --- pkg/scheduler/framework/session.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/scheduler/framework/session.go b/pkg/scheduler/framework/session.go index d4c66cc11..6783ad071 100644 --- a/pkg/scheduler/framework/session.go +++ b/pkg/scheduler/framework/session.go @@ -381,7 +381,12 @@ func (ssn *Session) JobOrderFn(l, r interface{}) bool { lv := l.(*api.JobInfo) rv := r.(*api.JobInfo) - return lv.UID < rv.UID + if lv.CreationTimestamp.Equal(&rv.CreationTimestamp) { + return lv.UID < rv.UID + } + + return lv.CreationTimestamp.Before(&rv.CreationTimestamp) + } func (ssn *Session) QueueOrderFn(l, r interface{}) bool {