diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/jdbc/JdbcJobExecutionDao.java b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/jdbc/JdbcJobExecutionDao.java
index 0872c21d4e..e6b9d76476 100644
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/jdbc/JdbcJobExecutionDao.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/jdbc/JdbcJobExecutionDao.java
@@ -217,10 +217,8 @@ public List<JobExecution> findJobExecutions(final JobInstance jobInstance) {
 		Assert.notNull(jobInstance, "Job instance cannot be null.");
 		long jobInstanceId = jobInstance.getId();
 		// TODO optimize to a single query with a join if possible
-		List<Long> jobExecutionIds = getJdbcTemplate()
-			.queryForStream(getQuery(GET_JOB_EXECUTION_IDS_BY_INSTANCE_ID), (rs, rowNum) -> rs.getLong(1),
-					jobInstanceId)
-			.toList();
+		List<Long> jobExecutionIds = getJdbcTemplate().queryForList(getQuery(GET_JOB_EXECUTION_IDS_BY_INSTANCE_ID),
+				Long.class, jobInstanceId);
 		List<JobExecution> jobExecutions = new ArrayList<>(jobExecutionIds.size());
 		for (Long jobExecutionId : jobExecutionIds) {
 			jobExecutions.add(getJobExecution(jobExecutionId));