This is an automated email from the ASF dual-hosted git repository.
mani pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/yunikorn-core.git
The following commit(s) were added to refs/heads/master by this push:
new 6cb34810 [YUNIKORN-2427] reverting addendum commit
6cb34810 is described below
commit 6cb348108678f74e00a0d3c378a47529376a6b4b
Author: Manikandan R <[email protected]>
AuthorDate: Wed Feb 21 17:15:45 2024 +0530
[YUNIKORN-2427] reverting addendum commit
---
pkg/scheduler/ugm/user_tracker.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/pkg/scheduler/ugm/user_tracker.go
b/pkg/scheduler/ugm/user_tracker.go
index 61e49a97..b93b5396 100644
--- a/pkg/scheduler/ugm/user_tracker.go
+++ b/pkg/scheduler/ugm/user_tracker.go
@@ -122,8 +122,8 @@ func (ut *UserTracker) setLimits(hierarchy []string,
resource *resources.Resourc
}
func (ut *UserTracker) headroom(hierarchy []string) *resources.Resource {
- ut.RLock()
- defer ut.RUnlock()
+ ut.Lock()
+ defer ut.Unlock()
return ut.queueTracker.headroom(hierarchy, user)
}
@@ -168,7 +168,7 @@ func (ut *UserTracker) canBeRemoved() bool {
}
func (ut *UserTracker) canRunApp(hierarchy []string, applicationID string)
bool {
- ut.RLock()
- defer ut.RUnlock()
+ ut.Lock()
+ defer ut.Unlock()
return ut.queueTracker.canRunApp(hierarchy, applicationID, user)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
