From e2b29cd5089257e84015a63ede78ec72ffcd527f Mon Sep 17 00:00:00 2001 From: ravisantoshgudimetla Date: Fri, 9 Aug 2019 15:23:28 -0400 Subject: [PATCH] Scheduler should terminate when it looses leader lock --- cmd/kube-scheduler/app/server.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/cmd/kube-scheduler/app/server.go b/cmd/kube-scheduler/app/server.go index 985480ebabc..60fe82b96c5 100644 --- a/cmd/kube-scheduler/app/server.go +++ b/cmd/kube-scheduler/app/server.go @@ -26,7 +26,6 @@ import ( goruntime "runtime" utilerrors "k8s.io/apimachinery/pkg/util/errors" - utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apiserver/pkg/authentication/authenticator" "k8s.io/apiserver/pkg/authorization/authorizer" genericapifilters "k8s.io/apiserver/pkg/endpoints/filters" @@ -262,7 +261,7 @@ func Run(cc schedulerserverconfig.CompletedConfig, stopCh <-chan struct{}, regis cc.LeaderElection.Callbacks = leaderelection.LeaderCallbacks{ OnStartedLeading: run, OnStoppedLeading: func() { - utilruntime.HandleError(fmt.Errorf("lost master")) + klog.Fatalf("leaderelection lost") }, } leaderElector, err := leaderelection.NewLeaderElector(*cc.LeaderElection)