JOB

private static AtomicLong executionOrder = new AtomicLong(0);

...

new QuerydslPagingItemReader<>(  
        entityManagerFactory,  
        executionOrder,  
        DEFAULT_CHUNK_SIZE,  
        queryFactory -> repository.newFindChangeBalanceMemberList(  
                startDate,  
                endDate  
        ));

long currentExecutionOrder = executionOrder.getAndIncrement();  
long startIndex = (currentExecutionOrder) * getPageSize();  
int totalRecords = stepContext.getInt("totalRecords");  
  
if (startIndex >= totalRecords) {  
    initResults(); // 빈 결과로 초기화  
    tx.commit();  
    return;  
}  
  
int chunkSizeToRead = Math.min(getPageSize(), (int) (totalRecords - startIndex)); // 남은 데이터 크기만큼 읽기  
  
// QueryDSL Query 생성  
JPQLQuery<T> query = createQuery()  
        .offset(startIndex)  
        .limit(chunkSizeToRead);

@Slf4j  
public class JobTimerExecutionListener implements JobExecutionListener {  
    private final String jobName;  
    private long startTime = System.currentTimeMillis();  
  
    public JobTimerExecutionListener(String jobName) {  
        this.jobName = jobName;  
    }  
  
    @Override  
    public void beforeJob(JobExecution var1) {  
        startTime = System.currentTimeMillis();  
    }  
  
    @Override  
    public void afterJob(JobExecution var1) {  
        long endTime = System.currentTimeMillis();  
        long elapsedTime = endTime - startTime;  
        long minutes = (elapsedTime / 1000) / 60; // 밀리초를 분으로 변환  
        double seconds = (elapsedTime / 1000.0) % 60; // 남은 밀리초를 초로 변환 (소수점 포함)  
        log.info("{}-completed: {} ms | {} minutes {} seconds", jobName, elapsedTime, minutes, seconds);  
    }  
}