This is an automated email from the ASF dual-hosted git repository.
pbacsko 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 620687af [YUNIKORN-2233] [ADDENDUM] Scheduler core cannot be stopped
properly
620687af is described below
commit 620687afe10638d3e191edffbc81959985abbbb4
Author: Peter Bacsko <[email protected]>
AuthorDate: Tue Dec 12 23:31:46 2023 +0100
[YUNIKORN-2233] [ADDENDUM] Scheduler core cannot be stopped properly
Avoid type cast in ServiceContext.StopAll() after updating SI version.
---
pkg/entrypoint/service_context.go | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/pkg/entrypoint/service_context.go
b/pkg/entrypoint/service_context.go
index bd6ff7f9..650c0c3f 100644
--- a/pkg/entrypoint/service_context.go
+++ b/pkg/entrypoint/service_context.go
@@ -24,7 +24,6 @@ import (
"github.com/apache/yunikorn-core/pkg/events"
"github.com/apache/yunikorn-core/pkg/log"
"github.com/apache/yunikorn-core/pkg/metrics"
- "github.com/apache/yunikorn-core/pkg/rmproxy"
"github.com/apache/yunikorn-core/pkg/scheduler"
"github.com/apache/yunikorn-core/pkg/webservice"
"github.com/apache/yunikorn-scheduler-interface/lib/go/api"
@@ -49,8 +48,6 @@ func (s *ServiceContext) StopAll() {
s.MetricsCollector.Stop()
}
s.Scheduler.Stop()
- if proxyImpl, ok := s.RMProxy.(*rmproxy.RMProxy); ok {
- proxyImpl.Stop()
- }
+ s.RMProxy.Stop()
events.GetEventSystem().Stop()
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
