diff --git a/pkg/controller/mpi_job_controller.go b/pkg/controller/mpi_job_controller.go
index c161de9e..d6b2ffc1 100644
--- a/pkg/controller/mpi_job_controller.go
+++ b/pkg/controller/mpi_job_controller.go
@@ -808,7 +808,7 @@ func (c *MPIJobController) getRunningWorkerPods(mpiJob *kubeflow.MPIJob) ([]*cor
 	if err != nil {
 		return nil, err
 	}
-	podFullList, err := c.podLister.List(selector)
+	podFullList, err := c.podLister.Pods(mpiJob.Namespace).List(selector)
 	if err != nil {
 		return nil, err
 	}
@@ -956,7 +956,7 @@ func (c *MPIJobController) getOrCreateWorker(mpiJob *kubeflow.MPIJob) ([]*corev1
 	if err != nil {
 		return nil, err
 	}
-	podFullList, err := c.podLister.List(selector)
+	podFullList, err := c.podLister.Pods(mpiJob.Namespace).List(selector)
 	if err != nil {
 		return nil, err
 	}