[YUNIKORN-1093] Track rejected applications

steinsgateted · Mar 6, 2022 · 45ebe12 · 45ebe12
1 parent 7dadbb8
commit 45ebe12
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/scheduler/context.go b/pkg/scheduler/context.go
@@ -519,8 +519,7 @@ func (cc *ClusterContext) handleRMUpdateApplicationEvent(event *rmevent.RMUpdate
 				ApplicationID: app.ApplicationID,
 				Reason:        err.Error(),
 			})
-			rejectedApp := objects.NewApplication(app, ugi, cc.rmEventHandler, request.RmID)
-			partition.addRejectedApplication(rejectedApp, err.Error())
+			partition.addRejectedApplication(schedApp, err.Error())
 
 			log.Logger().Error("Failed to add application to partition (placement rejected)",
 				zap.String("applicationID", app.ApplicationID),

diff --git a/pkg/scheduler/partition.go b/pkg/scheduler/partition.go
@@ -1118,6 +1118,7 @@ func (pc *PartitionContext) GetAppsByState(state string) []*objects.Application
 	return appList
 }
 
+// used to find expired apps in rejected applications
 func (pc *PartitionContext) GetRejectedAppsByState(state string) []*objects.Application {
 	pc.RLock()
 	defer pc.RUnlock()