Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@

/**
* @author Mahmoud Ben Hassine
* @author Yanming Zhou
* @since 5.2.0
*/
public class MongoStepExecutionDao implements StepExecutionDao {
Expand Down Expand Up @@ -130,7 +131,8 @@ public StepExecution getLastStepExecution(JobInstance jobInstance, String stepNa
.filter(stepExecution -> stepExecution.getName().equals(stepName))
.max(Comparator
.comparing(org.springframework.batch.core.repository.persistence.StepExecution::getCreateTime)
.thenComparing(org.springframework.batch.core.repository.persistence.StepExecution::getId));
.thenComparing(
org.springframework.batch.core.repository.persistence.StepExecution::getStepExecutionId));
if (lastStepExecution.isPresent()) {
org.springframework.batch.core.repository.persistence.StepExecution stepExecution = lastStepExecution.get();
JobExecution jobExecution = this.jobExecutionConverter.toJobExecution(jobExecutions.stream()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,11 @@

/**
* @author Mahmoud Ben Hassine
* @author Yanming Zhou
* @since 5.2.0
*/
public class JobExecution {

private String id;

private long jobExecutionId;

private long jobInstanceId;
Expand All @@ -53,13 +52,6 @@ public class JobExecution {

private ExecutionContext executionContext;

public JobExecution() {
}

public String getId() {
return id;
}

public long getJobInstanceId() {
return jobInstanceId;
}
Expand Down Expand Up @@ -150,11 +142,10 @@ public void setExecutionContext(ExecutionContext executionContext) {

@Override
public String toString() {
return "JobExecution{" + "id='" + id + '\'' + ", jobExecutionId=" + jobExecutionId + ", jobInstanceId="
+ jobInstanceId + ", jobParameters=" + jobParameters + ", stepExecutions=" + stepExecutions
+ ", status=" + status + ", startTime=" + startTime + ", createTime=" + createTime + ", endTime="
+ endTime + ", lastUpdated=" + lastUpdated + ", exitStatus=" + exitStatus + ", executionContext="
+ executionContext + '}';
return "JobExecution{jobExecutionId=" + jobExecutionId + ", jobInstanceId=" + jobInstanceId + ", jobParameters="
+ jobParameters + ", stepExecutions=" + stepExecutions + ", status=" + status + ", startTime="
+ startTime + ", createTime=" + createTime + ", endTime=" + endTime + ", lastUpdated=" + lastUpdated
+ ", exitStatus=" + exitStatus + ", executionContext=" + executionContext + '}';
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -17,25 +17,17 @@

/**
* @author Mahmoud Ben Hassine
* @author Yanming Zhou
* @since 5.2.0
*/
public class JobInstance {

private String id;

private long jobInstanceId;

private String jobName;

private String jobKey;

public JobInstance() {
}

public String getId() {
return id;
}

public long getJobInstanceId() {
return jobInstanceId;
}
Expand All @@ -62,8 +54,8 @@ public void setJobKey(String jobKey) {

@Override
public String toString() {
return "JobInstance{" + "id='" + id + '\'' + ", jobInstanceId=" + jobInstanceId + ", jobName='" + jobName + '\''
+ ", jobKey='" + jobKey + '\'' + '}';
return "JobInstance{jobInstanceId=" + jobInstanceId + ", jobName='" + jobName + '\'' + ", jobKey='" + jobKey
+ '\'' + '}';
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -21,12 +21,11 @@

/**
* @author Mahmoud Ben Hassine
* @author Yanming Zhou
* @since 5.2.0
*/
public class StepExecution {

private String id;

private long stepExecutionId;

private long jobExecutionId;
Expand Down Expand Up @@ -65,13 +64,6 @@ public class StepExecution {

private boolean terminateOnly;

public StepExecution() {
}

public String getId() {
return id;
}

public long getStepExecutionId() {
return stepExecutionId;
}
Expand Down Expand Up @@ -226,13 +218,13 @@ public void setTerminateOnly(boolean terminateOnly) {

@Override
public String toString() {
return "StepExecution{" + "id='" + id + '\'' + ", stepExecutionId=" + stepExecutionId + ", jobExecutionId='"
+ jobExecutionId + '\'' + ", name='" + name + '\'' + ", status=" + status + ", readCount=" + readCount
+ ", writeCount=" + writeCount + ", commitCount=" + commitCount + ", rollbackCount=" + rollbackCount
+ ", readSkipCount=" + readSkipCount + ", processSkipCount=" + processSkipCount + ", writeSkipCount="
+ writeSkipCount + ", filterCount=" + filterCount + ", startTime=" + startTime + ", createTime="
+ createTime + ", endTime=" + endTime + ", lastUpdated=" + lastUpdated + ", executionContext="
+ executionContext + ", exitStatus=" + exitStatus + ", terminateOnly=" + terminateOnly + '}';
return "StepExecution{stepExecutionId=" + stepExecutionId + ", jobExecutionId='" + jobExecutionId + '\''
+ ", name='" + name + '\'' + ", status=" + status + ", readCount=" + readCount + ", writeCount="
+ writeCount + ", commitCount=" + commitCount + ", rollbackCount=" + rollbackCount + ", readSkipCount="
+ readSkipCount + ", processSkipCount=" + processSkipCount + ", writeSkipCount=" + writeSkipCount
+ ", filterCount=" + filterCount + ", startTime=" + startTime + ", createTime=" + createTime
+ ", endTime=" + endTime + ", lastUpdated=" + lastUpdated + ", executionContext=" + executionContext
+ ", exitStatus=" + exitStatus + ", terminateOnly=" + terminateOnly + '}';
}

}