diff --git a/test/e2e/latency.go b/test/e2e/latency.go
index 7bb96a7aadf0..f1526654e329 100644
--- a/test/e2e/latency.go
+++ b/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)
diff --git a/test/e2e/nodeoutofdisk.go b/test/e2e/nodeoutofdisk.go
index 51518f2e3e3f..8e639729a5c1 100644
--- a/test/e2e/nodeoutofdisk.go
+++ b/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}
diff --git a/test/e2e/scheduler_predicates.go b/test/e2e/scheduler_predicates.go
index cffb681a6dc0..e286ed8dab9b 100644
--- a/test/e2e/scheduler_predicates.go
+++ b/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}