Change metrics type from int to long in StepExecution

fmbenhassine · fmbenhassine · commit 94c9402b38cb · 2021-01-29T14:35:47.000+01:00
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/StepContribution.java b/spring-batch-core/src/main/java/org/springframework/batch/core/StepContribution.java
@@ -28,19 +28,19 @@
 @SuppressWarnings("serial")
 public class StepContribution implements Serializable {
 
-	private volatile int readCount = 0;
+	private volatile long readCount = 0;
 
-	private volatile int writeCount = 0;
+	private volatile long writeCount = 0;
 
-	private volatile int filterCount = 0;
+	private volatile long filterCount = 0;
 
-	private final int parentSkipCount;
+	private final long parentSkipCount;
 
-	private volatile int readSkipCount;
+	private volatile long readSkipCount;
 
-	private volatile int writeSkipCount;
+	private volatile long writeSkipCount;
 
-	private volatile int processSkipCount;
+	private volatile long processSkipCount;
 
 	private ExitStatus exitStatus = ExitStatus.EXECUTING;
 
@@ -78,7 +78,7 @@ public ExitStatus getExitStatus() {
 	 *
 	 * @param count int amount to increment by.
 	 */
-	public void incrementFilterCount(int count) {
+	public void incrementFilterCount(long count) {
 		filterCount += count;
 	}
 
@@ -94,7 +94,7 @@ public void incrementReadCount() {
 	 *
 	 * @param count int amount to increment by.
 	 */
-	public void incrementWriteCount(int count) {
+	public void incrementWriteCount(long count) {
 		writeCount += count;
 	}
 
@@ -103,7 +103,7 @@ public void incrementWriteCount(int count) {
 	 *
 	 * @return the item counter.
 	 */
-	public int getReadCount() {
+	public long getReadCount() {
 		return readCount;
 	}
 
@@ -112,7 +112,7 @@ public int getReadCount() {
 	 *
 	 * @return the item counter.
 	 */
-	public int getWriteCount() {
+	public long getWriteCount() {
 		return writeCount;
 	}
 
@@ -121,15 +121,15 @@ public int getWriteCount() {
 	 *
 	 * @return the filter counter
 	 */
-	public int getFilterCount() {
+	public long getFilterCount() {
 		return filterCount;
 	}
 
 	/**
 	 * @return the sum of skips accumulated in the parent {@link StepExecution}
 	 * and this <code>StepContribution</code>.
 	 */
-	public int getStepSkipCount() {
+	public long getStepSkipCount() {
 		return readSkipCount + writeSkipCount + processSkipCount + parentSkipCount;
 	}
 
@@ -138,7 +138,7 @@ public int getStepSkipCount() {
 	 * <code>StepContribution</code> (not including skips accumulated in the
 	 * parent {@link StepExecution}).
 	 */
-	public int getSkipCount() {
+	public long getSkipCount() {
 		return readSkipCount + writeSkipCount + processSkipCount;
 	}
 
@@ -154,7 +154,7 @@ public void incrementReadSkipCount() {
 	 *
 	 * @param count int amount to increment by.
 	 */
-	public void incrementReadSkipCount(int count) {
+	public void incrementReadSkipCount(long count) {
 		readSkipCount += count;
 	}
 
@@ -175,14 +175,14 @@ public void incrementProcessSkipCount() {
 	/**
 	 * @return the read skip count
 	 */
-	public int getReadSkipCount() {
+	public long getReadSkipCount() {
 		return readSkipCount;
 	}
 
 	/**
 	 * @return the write skip count
 	 */
-	public int getWriteSkipCount() {
+	public long getWriteSkipCount() {
 		return writeSkipCount;
 	}
 
@@ -191,7 +191,7 @@ public int getWriteSkipCount() {
 	 *
 	 * @return the process skip count
 	 */
-	public int getProcessSkipCount() {
+	public long getProcessSkipCount() {
 		return processSkipCount;
 	}
 
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/StepExecution.java b/spring-batch-core/src/main/java/org/springframework/batch/core/StepExecution.java
@@ -44,19 +44,19 @@ public class StepExecution extends Entity {
 
 	private volatile BatchStatus status = BatchStatus.STARTING;
 
-	private volatile int readCount = 0;
+	private volatile long readCount = 0;
 
-	private volatile int writeCount = 0;
+	private volatile long writeCount = 0;
 
-	private volatile int commitCount = 0;
+	private volatile long commitCount = 0;
 
-	private volatile int rollbackCount = 0;
+	private volatile long rollbackCount = 0;
 
-	private volatile int readSkipCount = 0;
+	private volatile long readSkipCount = 0;
 
-	private volatile int processSkipCount = 0;
+	private volatile long processSkipCount = 0;
 
-	private volatile int writeSkipCount = 0;
+	private volatile long writeSkipCount = 0;
 
 	private volatile Date startTime = new Date(System.currentTimeMillis());
 
@@ -70,7 +70,7 @@ public class StepExecution extends Entity {
 
 	private volatile boolean terminateOnly;
 
-	private volatile int filterCount;
+	private volatile long filterCount;
 
 	private transient volatile List<Throwable> failureExceptions = new CopyOnWriteArrayList<>();
 
@@ -140,7 +140,7 @@ public void setExecutionContext(ExecutionContext executionContext) {
 	 *
 	 * @return the current number of commits
 	 */
-	public int getCommitCount() {
+	public long getCommitCount() {
 		return commitCount;
 	}
 
@@ -149,7 +149,7 @@ public int getCommitCount() {
 	 *
 	 * @param commitCount the current number of commits
 	 */
-	public void setCommitCount(int commitCount) {
+	public void setCommitCount(long commitCount) {
 		this.commitCount = commitCount;
 	}
 
@@ -176,7 +176,7 @@ public void setEndTime(Date endTime) {
 	 *
 	 * @return the current number of items read for this execution
 	 */
-	public int getReadCount() {
+	public long getReadCount() {
 		return readCount;
 	}
 
@@ -185,7 +185,7 @@ public int getReadCount() {
 	 *
 	 * @param readCount the current number of read items for this execution
 	 */
-	public void setReadCount(int readCount) {
+	public void setReadCount(long readCount) {
 		this.readCount = readCount;
 	}
 
@@ -194,7 +194,7 @@ public void setReadCount(int readCount) {
 	 *
 	 * @return the current number of items written for this execution
 	 */
-	public int getWriteCount() {
+	public long getWriteCount() {
 		return writeCount;
 	}
 
@@ -203,7 +203,7 @@ public int getWriteCount() {
 	 *
 	 * @param writeCount the current number of written items for this execution
 	 */
-	public void setWriteCount(int writeCount) {
+	public void setWriteCount(long writeCount) {
 		this.writeCount = writeCount;
 	}
 
@@ -212,7 +212,7 @@ public void setWriteCount(int writeCount) {
 	 *
 	 * @return the current number of rollbacks for this execution
 	 */
-	public int getRollbackCount() {
+	public long getRollbackCount() {
 		return rollbackCount;
 	}
 
@@ -221,7 +221,7 @@ public int getRollbackCount() {
 	 *
 	 * @return the current number of items filtered out of this execution
 	 */
-	public int getFilterCount() {
+	public long getFilterCount() {
 		return filterCount;
 	}
 
@@ -230,15 +230,15 @@ public int getFilterCount() {
 	 * @param filterCount the number of items filtered out of this execution to
 	 * set
 	 */
-	public void setFilterCount(int filterCount) {
+	public void setFilterCount(long filterCount) {
 		this.filterCount = filterCount;
 	}
 
 	/**
 	 * Setter for number of rollbacks for this execution
 	 * @param rollbackCount int the number of rollbacks.
 	 */
-	public void setRollbackCount(int rollbackCount) {
+	public void setRollbackCount(long rollbackCount) {
 		this.rollbackCount = rollbackCount;
 	}
 
@@ -383,7 +383,7 @@ public void setTerminateOnly() {
 	/**
 	 * @return the total number of items skipped.
 	 */
-	public int getSkipCount() {
+	public long getSkipCount() {
 		return readSkipCount + processSkipCount + writeSkipCount;
 	}
 
@@ -410,14 +410,14 @@ public JobParameters getJobParameters() {
 	/**
 	 * @return the number of records skipped on read
 	 */
-	public int getReadSkipCount() {
+	public long getReadSkipCount() {
 		return readSkipCount;
 	}
 
 	/**
 	 * @return the number of records skipped on write
 	 */
-	public int getWriteSkipCount() {
+	public long getWriteSkipCount() {
 		return writeSkipCount;
 	}
 
@@ -426,7 +426,7 @@ public int getWriteSkipCount() {
 	 *
 	 * @param readSkipCount int containing read skip count to be used for the step execution.
 	 */
-	public void setReadSkipCount(int readSkipCount) {
+	public void setReadSkipCount(long readSkipCount) {
 		this.readSkipCount = readSkipCount;
 	}
 
@@ -435,14 +435,14 @@ public void setReadSkipCount(int readSkipCount) {
 	 *
 	 * @param writeSkipCount int containing write skip count to be used for the step execution.
 	 */
-	public void setWriteSkipCount(int writeSkipCount) {
+	public void setWriteSkipCount(long writeSkipCount) {
 		this.writeSkipCount = writeSkipCount;
 	}
 
 	/**
 	 * @return the number of records skipped during processing
 	 */
-	public int getProcessSkipCount() {
+	public long getProcessSkipCount() {
 		return processSkipCount;
 	}
 
@@ -451,7 +451,7 @@ public int getProcessSkipCount() {
 	 *
 	 * @param processSkipCount int containing process skip count to be used for the step execution.
 	 */
-	public void setProcessSkipCount(int processSkipCount) {
+	public void setProcessSkipCount(long processSkipCount) {
 		this.processSkipCount = processSkipCount;
 	}
 
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/item/JsrFaultTolerantChunkProcessor.java b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/item/JsrFaultTolerantChunkProcessor.java
@@ -193,7 +193,7 @@ public I recover(RetryContext context) throws Exception {
 	 * @param e the cause of the skip
 	 * @param skipCount the current skip count
 	 */
-	private boolean shouldSkip(SkipPolicy policy, Throwable e, int skipCount) {
+	private boolean shouldSkip(SkipPolicy policy, Throwable e, long skipCount) {
 		try {
 			return policy.shouldSkip(e, skipCount);
 		}
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantChunkProcessor.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantChunkProcessor.java
@@ -514,7 +514,7 @@ private void callProcessSkipListener(I item, Throwable e) {
 	 * @param e the cause of the skip
 	 * @param skipCount the current skip count
 	 */
-	private boolean shouldSkip(SkipPolicy policy, Throwable e, int skipCount) {
+	private boolean shouldSkip(SkipPolicy policy, Throwable e, long skipCount) {
 		try {
 			return policy.shouldSkip(e, skipCount);
 		}
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantChunkProvider.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantChunkProvider.java
@@ -130,7 +130,7 @@ public void postProcess(StepContribution contribution, Chunk<I> chunk) {
 	 * @param e the cause of the skip
 	 * @param skipCount the current skip count
 	 */
-	private boolean shouldSkip(SkipPolicy policy, Throwable e, int skipCount) {
+	private boolean shouldSkip(SkipPolicy policy, Throwable e, long skipCount) {
 		try {
 			return policy.shouldSkip(e, skipCount);
 		}
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/AlwaysSkipItemSkipPolicy.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/AlwaysSkipItemSkipPolicy.java
@@ -26,7 +26,7 @@
 public class AlwaysSkipItemSkipPolicy implements SkipPolicy {
 
 	@Override
-	public boolean shouldSkip(Throwable t, int skipCount) {
+	public boolean shouldSkip(Throwable t, long skipCount) {
 		return true;
 	}
 
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/CompositeSkipPolicy.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/CompositeSkipPolicy.java
@@ -36,7 +36,7 @@ public void setSkipPolicies(SkipPolicy[] skipPolicies) {
 	}
 
 	@Override
-	public boolean shouldSkip(Throwable t, int skipCount) throws SkipLimitExceededException {
+	public boolean shouldSkip(Throwable t, long skipCount) throws SkipLimitExceededException {
 		for (SkipPolicy policy : skipPolicies) {
 			if (policy.shouldSkip(t, skipCount)) {
 				return true;
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/ExceptionClassifierSkipPolicy.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/ExceptionClassifierSkipPolicy.java
@@ -66,7 +66,7 @@ public void setPolicyMap(Map<Class<? extends Throwable>, SkipPolicy> policyMap)
 	 * @throws SkipLimitExceededException if a limit is exceeded
 	 */
 	@Override
-	public boolean shouldSkip(Throwable t, int skipCount) throws SkipLimitExceededException {
+	public boolean shouldSkip(Throwable t, long skipCount) throws SkipLimitExceededException {
 		return classifier.classify(t).shouldSkip(t, skipCount);
 	}
 
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/LimitCheckingItemSkipPolicy.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/LimitCheckingItemSkipPolicy.java
@@ -124,7 +124,7 @@ public void setSkippableExceptionMap(Map<Class<? extends Throwable>, Boolean> sk
 	 * {@link SkipLimitExceededException} will be thrown.
 	 */
 	@Override
-	public boolean shouldSkip(Throwable t, int skipCount) {
+	public boolean shouldSkip(Throwable t, long skipCount) {
 		if (skippableExceptionClassifier.classify(t)) {
 			if (skipCount < skipLimit) {
 				return true;
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/NeverSkipItemSkipPolicy.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/NeverSkipItemSkipPolicy.java
@@ -25,7 +25,7 @@
 public class NeverSkipItemSkipPolicy implements SkipPolicy{
 
 	@Override
-	public boolean shouldSkip(Throwable t, int skipCount) {
+	public boolean shouldSkip(Throwable t, long skipCount) {
 		return false;
 	}
 
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/SkipPolicy.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/skip/SkipPolicy.java
@@ -38,6 +38,6 @@ public interface SkipPolicy {
 	 * @throws SkipLimitExceededException if a limit is breached
 	 * @throws IllegalArgumentException if the exception is null
 	 */
-	boolean shouldSkip(Throwable t, int skipCount) throws SkipLimitExceededException;
+	boolean shouldSkip(Throwable t, long skipCount) throws SkipLimitExceededException;
 
 }
diff --git a/spring-batch-core/src/test/java/org/springframework/batch/core/step/item/FaultTolerantStepFactoryBeanTests.java b/spring-batch-core/src/test/java/org/springframework/batch/core/step/item/FaultTolerantStepFactoryBeanTests.java
diff --git a/spring-batch-core/src/test/java/org/springframework/batch/core/test/football/FootballJobSkipIntegrationTests.java b/spring-batch-core/src/test/java/org/springframework/batch/core/test/football/FootballJobSkipIntegrationTests.java
diff --git a/spring-batch-core/src/test/java/org/springframework/batch/core/test/step/FaultTolerantStepIntegrationTests.java b/spring-batch-core/src/test/java/org/springframework/batch/core/test/step/FaultTolerantStepIntegrationTests.java
diff --git a/spring-batch-samples/src/test/java/org/springframework/batch/sample/common/ErrorLogTasklet.java b/spring-batch-samples/src/test/java/org/springframework/batch/sample/common/ErrorLogTasklet.java

Original file line number	Diff line number	Diff line change
`@@ -44,19 +44,19 @@ public class StepExecution extends Entity {`
`44`	`44`
`45`	`45`	`private volatile BatchStatus status = BatchStatus.STARTING;`
`46`	`46`
`47`		`- private volatile int readCount = 0;`
	`47`	`+ private volatile long readCount = 0;`
`48`	`48`
`49`		`- private volatile int writeCount = 0;`
	`49`	`+ private volatile long writeCount = 0;`
`50`	`50`
`51`		`- private volatile int commitCount = 0;`
	`51`	`+ private volatile long commitCount = 0;`
`52`	`52`
`53`		`- private volatile int rollbackCount = 0;`
	`53`	`+ private volatile long rollbackCount = 0;`
`54`	`54`
`55`		`- private volatile int readSkipCount = 0;`
	`55`	`+ private volatile long readSkipCount = 0;`
`56`	`56`
`57`		`- private volatile int processSkipCount = 0;`
	`57`	`+ private volatile long processSkipCount = 0;`
`58`	`58`
`59`		`- private volatile int writeSkipCount = 0;`
	`59`	`+ private volatile long writeSkipCount = 0;`
`60`	`60`
`61`	`61`	`private volatile Date startTime = new Date(System.currentTimeMillis());`
`62`	`62`
`@@ -70,7 +70,7 @@ public class StepExecution extends Entity {`
`70`	`70`
`71`	`71`	`private volatile boolean terminateOnly;`
`72`	`72`
`73`		`- private volatile int filterCount;`
	`73`	`+ private volatile long filterCount;`
`74`	`74`
`75`	`75`	`private transient volatile List<Throwable> failureExceptions = new CopyOnWriteArrayList<>();`
`76`	`76`
`@@ -140,7 +140,7 @@ public void setExecutionContext(ExecutionContext executionContext) {`
`140`	`140`	`*`
`141`	`141`	`* @return the current number of commits`
`142`	`142`	`*/`
`143`		`- public int getCommitCount() {`
	`143`	`+ public long getCommitCount() {`
`144`	`144`	`return commitCount;`
`145`	`145`	`}`
`146`	`146`
`@@ -149,7 +149,7 @@ public int getCommitCount() {`
`149`	`149`	`*`
`150`	`150`	`* @param commitCount the current number of commits`
`151`	`151`	`*/`
`152`		`- public void setCommitCount(int commitCount) {`
	`152`	`+ public void setCommitCount(long commitCount) {`
`153`	`153`	`this.commitCount = commitCount;`
`154`	`154`	`}`
`155`	`155`
`@@ -176,7 +176,7 @@ public void setEndTime(Date endTime) {`
`176`	`176`	`*`
`177`	`177`	`* @return the current number of items read for this execution`
`178`	`178`	`*/`
`179`		`- public int getReadCount() {`
	`179`	`+ public long getReadCount() {`
`180`	`180`	`return readCount;`
`181`	`181`	`}`
`182`	`182`
`@@ -185,7 +185,7 @@ public int getReadCount() {`
`185`	`185`	`*`
`186`	`186`	`* @param readCount the current number of read items for this execution`
`187`	`187`	`*/`
`188`		`- public void setReadCount(int readCount) {`
	`188`	`+ public void setReadCount(long readCount) {`
`189`	`189`	`this.readCount = readCount;`
`190`	`190`	`}`
`191`	`191`
`@@ -194,7 +194,7 @@ public void setReadCount(int readCount) {`
`194`	`194`	`*`
`195`	`195`	`* @return the current number of items written for this execution`
`196`	`196`	`*/`
`197`		`- public int getWriteCount() {`
	`197`	`+ public long getWriteCount() {`
`198`	`198`	`return writeCount;`
`199`	`199`	`}`
`200`	`200`
`@@ -203,7 +203,7 @@ public int getWriteCount() {`
`203`	`203`	`*`
`204`	`204`	`* @param writeCount the current number of written items for this execution`
`205`	`205`	`*/`
`206`		`- public void setWriteCount(int writeCount) {`
	`206`	`+ public void setWriteCount(long writeCount) {`
`207`	`207`	`this.writeCount = writeCount;`
`208`	`208`	`}`
`209`	`209`
`@@ -212,7 +212,7 @@ public void setWriteCount(int writeCount) {`
`212`	`212`	`*`
`213`	`213`	`* @return the current number of rollbacks for this execution`
`214`	`214`	`*/`
`215`		`- public int getRollbackCount() {`
	`215`	`+ public long getRollbackCount() {`
`216`	`216`	`return rollbackCount;`
`217`	`217`	`}`
`218`	`218`
`@@ -221,7 +221,7 @@ public int getRollbackCount() {`
`221`	`221`	`*`
`222`	`222`	`* @return the current number of items filtered out of this execution`
`223`	`223`	`*/`
`224`		`- public int getFilterCount() {`
	`224`	`+ public long getFilterCount() {`
`225`	`225`	`return filterCount;`
`226`	`226`	`}`
`227`	`227`
`@@ -230,15 +230,15 @@ public int getFilterCount() {`
`230`	`230`	`* @param filterCount the number of items filtered out of this execution to`
`231`	`231`	`* set`
`232`	`232`	`*/`
`233`		`- public void setFilterCount(int filterCount) {`
	`233`	`+ public void setFilterCount(long filterCount) {`
`234`	`234`	`this.filterCount = filterCount;`
`235`	`235`	`}`
`236`	`236`
`237`	`237`	`/**`
`238`	`238`	`* Setter for number of rollbacks for this execution`
`239`	`239`	`* @param rollbackCount int the number of rollbacks.`
`240`	`240`	`*/`
`241`		`- public void setRollbackCount(int rollbackCount) {`
	`241`	`+ public void setRollbackCount(long rollbackCount) {`
`242`	`242`	`this.rollbackCount = rollbackCount;`
`243`	`243`	`}`
`244`	`244`
`@@ -383,7 +383,7 @@ public void setTerminateOnly() {`
`383`	`383`	`/**`
`384`	`384`	`* @return the total number of items skipped.`
`385`	`385`	`*/`
`386`		`- public int getSkipCount() {`
	`386`	`+ public long getSkipCount() {`
`387`	`387`	`return readSkipCount + processSkipCount + writeSkipCount;`
`388`	`388`	`}`
`389`	`389`
`@@ -410,14 +410,14 @@ public JobParameters getJobParameters() {`
`410`	`410`	`/**`
`411`	`411`	`* @return the number of records skipped on read`
`412`	`412`	`*/`
`413`		`- public int getReadSkipCount() {`
	`413`	`+ public long getReadSkipCount() {`
`414`	`414`	`return readSkipCount;`
`415`	`415`	`}`
`416`	`416`
`417`	`417`	`/**`
`418`	`418`	`* @return the number of records skipped on write`
`419`	`419`	`*/`
`420`		`- public int getWriteSkipCount() {`
	`420`	`+ public long getWriteSkipCount() {`
`421`	`421`	`return writeSkipCount;`
`422`	`422`	`}`
`423`	`423`
`@@ -426,7 +426,7 @@ public int getWriteSkipCount() {`
`426`	`426`	`*`
`427`	`427`	`* @param readSkipCount int containing read skip count to be used for the step execution.`
`428`	`428`	`*/`
`429`		`- public void setReadSkipCount(int readSkipCount) {`
	`429`	`+ public void setReadSkipCount(long readSkipCount) {`
`430`	`430`	`this.readSkipCount = readSkipCount;`
`431`	`431`	`}`
`432`	`432`
`@@ -435,14 +435,14 @@ public void setReadSkipCount(int readSkipCount) {`
`435`	`435`	`*`
`436`	`436`	`* @param writeSkipCount int containing write skip count to be used for the step execution.`
`437`	`437`	`*/`
`438`		`- public void setWriteSkipCount(int writeSkipCount) {`
	`438`	`+ public void setWriteSkipCount(long writeSkipCount) {`
`439`	`439`	`this.writeSkipCount = writeSkipCount;`
`440`	`440`	`}`
`441`	`441`
`442`	`442`	`/**`
`443`	`443`	`* @return the number of records skipped during processing`
`444`	`444`	`*/`
`445`		`- public int getProcessSkipCount() {`
	`445`	`+ public long getProcessSkipCount() {`
`446`	`446`	`return processSkipCount;`
`447`	`447`	`}`
`448`	`448`
`@@ -451,7 +451,7 @@ public int getProcessSkipCount() {`
`451`	`451`	`*`
`452`	`452`	`* @param processSkipCount int containing process skip count to be used for the step execution.`
`453`	`453`	`*/`
`454`		`- public void setProcessSkipCount(int processSkipCount) {`
	`454`	`+ public void setProcessSkipCount(long processSkipCount) {`
`455`	`455`	`this.processSkipCount = processSkipCount;`
`456`	`456`	`}`
`457`	`457`
Original file line number	Diff line number	Diff line change
`@@ -193,7 +193,7 @@ public I recover(RetryContext context) throws Exception {`
`193`	`193`	`* @param e the cause of the skip`
`194`	`194`	`* @param skipCount the current skip count`
`195`	`195`	`*/`
`196`		`- private boolean shouldSkip(SkipPolicy policy, Throwable e, int skipCount) {`
	`196`	`+ private boolean shouldSkip(SkipPolicy policy, Throwable e, long skipCount) {`
`197`	`197`	`try {`
`198`	`198`	`return policy.shouldSkip(e, skipCount);`
`199`	`199`	`}`
Original file line number	Diff line number	Diff line change
`@@ -514,7 +514,7 @@ private void callProcessSkipListener(I item, Throwable e) {`
`514`	`514`	`* @param e the cause of the skip`
`515`	`515`	`* @param skipCount the current skip count`
`516`	`516`	`*/`
`517`		`- private boolean shouldSkip(SkipPolicy policy, Throwable e, int skipCount) {`
	`517`	`+ private boolean shouldSkip(SkipPolicy policy, Throwable e, long skipCount) {`
`518`	`518`	`try {`
`519`	`519`	`return policy.shouldSkip(e, skipCount);`
`520`	`520`	`}`
Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,7 @@ public void postProcess(StepContribution contribution, Chunk<I> chunk) {`
`130`	`130`	`* @param e the cause of the skip`
`131`	`131`	`* @param skipCount the current skip count`
`132`	`132`	`*/`
`133`		`- private boolean shouldSkip(SkipPolicy policy, Throwable e, int skipCount) {`
	`133`	`+ private boolean shouldSkip(SkipPolicy policy, Throwable e, long skipCount) {`
`134`	`134`	`try {`
`135`	`135`	`return policy.shouldSkip(e, skipCount);`
`136`	`136`	`}`
Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,7 @@`
`26`	`26`	`public class AlwaysSkipItemSkipPolicy implements SkipPolicy {`
`27`	`27`
`28`	`28`	`@Override`
`29`		`- public boolean shouldSkip(Throwable t, int skipCount) {`
	`29`	`+ public boolean shouldSkip(Throwable t, long skipCount) {`
`30`	`30`	`return true;`
`31`	`31`	`}`
`32`	`32`
Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ public void setSkipPolicies(SkipPolicy[] skipPolicies) {`
`36`	`36`	`}`
`37`	`37`
`38`	`38`	`@Override`
`39`		`- public boolean shouldSkip(Throwable t, int skipCount) throws SkipLimitExceededException {`
	`39`	`+ public boolean shouldSkip(Throwable t, long skipCount) throws SkipLimitExceededException {`
`40`	`40`	`for (SkipPolicy policy : skipPolicies) {`
`41`	`41`	`if (policy.shouldSkip(t, skipCount)) {`
`42`	`42`	`return true;`
Original file line number	Diff line number	Diff line change
`@@ -66,7 +66,7 @@ public void setPolicyMap(Map<Class<? extends Throwable>, SkipPolicy> policyMap)`
`66`	`66`	`* @throws SkipLimitExceededException if a limit is exceeded`
`67`	`67`	`*/`
`68`	`68`	`@Override`
`69`		`- public boolean shouldSkip(Throwable t, int skipCount) throws SkipLimitExceededException {`
	`69`	`+ public boolean shouldSkip(Throwable t, long skipCount) throws SkipLimitExceededException {`
`70`	`70`	`return classifier.classify(t).shouldSkip(t, skipCount);`
`71`	`71`	`}`
`72`	`72`
Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@`
`25`	`25`	`public class NeverSkipItemSkipPolicy implements SkipPolicy{`
`26`	`26`
`27`	`27`	`@Override`
`28`		`- public boolean shouldSkip(Throwable t, int skipCount) {`
	`28`	`+ public boolean shouldSkip(Throwable t, long skipCount) {`
`29`	`29`	`return false;`
`30`	`30`	`}`
`31`	`31`
Original file line number	Diff line number	Diff line change
`@@ -38,6 +38,6 @@ public interface SkipPolicy {`
`38`	`38`	`* @throws SkipLimitExceededException if a limit is breached`
`39`	`39`	`* @throws IllegalArgumentException if the exception is null`
`40`	`40`	`*/`
`41`		`- boolean shouldSkip(Throwable t, int skipCount) throws SkipLimitExceededException;`
	`41`	`+ boolean shouldSkip(Throwable t, long skipCount) throws SkipLimitExceededException;`
`42`	`42`
`43`	`43`	`}`