Fix e2e tests broken in #17865

test/e2e/latency.go

@@ -192,7 +192,7 @@ func runLatencyTest(nodeCount int, c *client.Client, ns string) {
 	selector := fields.Set{
 		"involvedObject.kind":      "Pod",
 		"involvedObject.namespace": ns,
-		"source":                   "scheduler",
+		"source":                   api.DefaultSchedulerName,
 	}.AsSelector()
 	options := api.ListOptions{FieldSelector: selector}
 	schedEvents, err := c.Events(ns).List(options)

test/e2e/nodeoutofdisk.go

@@ -133,7 +133,7 @@ var _ = Describe("NodeOutOfDisk [Serial]", func() {
 				"involvedObject.kind":      "Pod",
 				"involvedObject.name":      pendingPodName,
 				"involvedObject.namespace": ns,
-				"source":                   "scheduler",
+				"source":                   api.DefaultSchedulerName,
 				"reason":                   "FailedScheduling",
 			}.AsSelector()
 			options := api.ListOptions{FieldSelector: selector}

test/e2e/scheduler_predicates.go

@@ -103,7 +103,7 @@ func verifyResult(c *client.Client, podName string, ns string) {
 		"involvedObject.kind":      "Pod",
 		"involvedObject.name":      podName,
 		"involvedObject.namespace": ns,
-		"source":                   "scheduler",
+		"source":                   api.DefaultSchedulerName,
 		"reason":                   "FailedScheduling",
 	}.AsSelector()
 	options := api.ListOptions{FieldSelector: selector}