diff --git a/execution/src/main/java/org/springframework/batch/execution/repository/dao/HibernateJobDao.java b/execution/src/main/java/org/springframework/batch/execution/repository/dao/HibernateJobDao.java
index 4f54c31e1..a06262940 100644
--- a/execution/src/main/java/org/springframework/batch/execution/repository/dao/HibernateJobDao.java
+++ b/execution/src/main/java/org/springframework/batch/execution/repository/dao/HibernateJobDao.java
@@ -207,7 +207,7 @@ public class HibernateJobDao extends HibernateDaoSupport implements JobDao {
 		if (jobIdentifier instanceof ScheduledJobIdentifier) {
 			ScheduledJobIdentifier jobRuntimeInformation = (ScheduledJobIdentifier) jobIdentifier;
 
-			Assert.notNull(jobRuntimeInformation.getJobStream(),
+			Assert.notNull(jobRuntimeInformation.getJobKey(),
 					"JobRuntimeInformation JobStream cannot be null.");
 			Assert.notNull(jobRuntimeInformation.getScheduleDate(),
 					"JobRuntimeInformation ScheduleDate cannot be null.");