Skip to content

Commit 2d5e6c9

Browse files
authored
fix: leader election use nodepool value for lock name (#411)
1 parent 5dfd6d8 commit 2d5e6c9

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

cmd/scheduler/app/server.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,11 @@ func Run(opt *options.ServerOption, config *restclient.Config, mux *http.ServeMu
193193
// Prepare event clients.
194194
broadcaster := record.NewBroadcaster()
195195
broadcaster.StartRecordingToSink(&corev1.EventSinkImpl{Interface: leaderElectionClient.CoreV1().Events(opt.Namspace)})
196-
eventRecorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: opt.SchedulerName})
196+
componentName := opt.SchedulerName
197+
if len(opt.NodePoolLabelValue) > 0 {
198+
componentName = fmt.Sprintf("%s-%s", opt.SchedulerName, opt.NodePoolLabelValue)
199+
}
200+
eventRecorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: componentName})
197201

198202
hostname, err := os.Hostname()
199203
if err != nil {
@@ -204,7 +208,7 @@ func Run(opt *options.ServerOption, config *restclient.Config, mux *http.ServeMu
204208

205209
rl, err := resourcelock.New(resourcelock.LeasesResourceLock,
206210
opt.Namspace,
207-
opt.SchedulerName,
211+
componentName,
208212
leaderElectionClient.CoreV1(),
209213
leaderElectionClient.CoordinationV1(),
210214
resourcelock.ResourceLockConfig{

0 commit comments

Comments
 (0)