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 8274f656 [YUNIKORN-2173] change log level to INFO for adding
allocation in queue (#725)
8274f656 is described below
commit 8274f6564177eee862d47f969173e102bdfdbb83
Author: Wilfred Spiegelenburg <[email protected]>
AuthorDate: Wed Nov 22 15:25:31 2023 +0530
[YUNIKORN-2173] change log level to INFO for adding allocation in queue
(#725)
Change the log level from DEBUG to INFO for the 3 locations where the
scheduling returns an allocation from an 'app.try...()' call.
Closes: #725
Signed-off-by: Manikandan R <[email protected]>
---
pkg/scheduler/objects/queue.go | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/pkg/scheduler/objects/queue.go b/pkg/scheduler/objects/queue.go
index d2afbcff..56339cb8 100644
--- a/pkg/scheduler/objects/queue.go
+++ b/pkg/scheduler/objects/queue.go
@@ -1312,7 +1312,7 @@ func (sq *Queue) TryAllocate(iterator func()
NodeIterator, fullIterator func() N
}
alloc := app.tryAllocate(headRoom, allowPreemption,
preemptionDelay, &preemptAttemptsRemaining, iterator, fullIterator, getnode)
if alloc != nil {
- log.Log(log.SchedQueue).Debug("allocation found
on queue",
+ log.Log(log.SchedQueue).Info("allocation found
on queue",
zap.String("queueName", sq.QueuePath),
zap.String("appID", app.ApplicationID),
zap.Stringer("allocation", alloc))
@@ -1348,7 +1348,7 @@ func (sq *Queue) TryPlaceholderAllocate(iterator func()
NodeIterator, getnode fu
for _, app := range sq.sortApplications(true, true) {
alloc := app.tryPlaceholderAllocate(iterator, getnode)
if alloc != nil {
- log.Log(log.SchedQueue).Debug("allocation found
on queue",
+ log.Log(log.SchedQueue).Info("allocation found
on queue",
zap.String("queueName", sq.QueuePath),
zap.String("appID", app.ApplicationID),
zap.Stringer("allocation", alloc))
@@ -1419,7 +1419,7 @@ func (sq *Queue) TryReservedAllocate(iterator func()
NodeIterator) *Allocation {
}
alloc := app.tryReservedAllocate(headRoom,
iterator)
if alloc != nil {
-
log.Log(log.SchedQueue).Debug("reservation found for allocation found on queue",
+
log.Log(log.SchedQueue).Info("reservation found for allocation found on queue",
zap.String("queueName",
sq.QueuePath),
zap.String("appID", appID),
zap.Stringer("allocation",
alloc),
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
