diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/builder/JsrFaultTolerantStepBuilder.java b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/builder/JsrFaultTolerantStepBuilder.java
index 641dee111..7e450d875 100644
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/builder/JsrFaultTolerantStepBuilder.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/builder/JsrFaultTolerantStepBuilder.java
@@ -63,8 +63,7 @@ public class JsrFaultTolerantStepBuilder<I, O> extends FaultTolerantStepBuilder<
 	@Override
 	@SuppressWarnings({"unchecked", "rawtypes"})
 	protected ChunkProcessor<I> createChunkProcessor() {
-		SkipPolicy skipPolicy = createSkipPolicy();
-		skipPolicy = getFatalExceptionAwareProxy(skipPolicy);
+		SkipPolicy skipPolicy = getFatalExceptionAwareProxy(createSkipPolicy());
 		JsrFaultTolerantChunkProcessor chunkProcessor = new JsrFaultTolerantChunkProcessor(getReader(), getProcessor(),
 				getWriter(), createChunkOperations(), createRetryOperations());
 		chunkProcessor.setSkipPolicy(skipPolicy);
diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/item/JsrChunkProcessor.java b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/item/JsrChunkProcessor.java
index 138872ad1..cd93c05b9 100644
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/item/JsrChunkProcessor.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/item/JsrChunkProcessor.java
@@ -101,7 +101,7 @@ public class JsrChunkProcessor<I,O> implements ChunkProcessor<I> {
 
 				O processedItem = transform(contribution, item);
 
-				if(item != null && processedItem == null) {
+				if(processedItem == null) {
 					filterCount.incrementAndGet();
 				} else {
 					output.add(processedItem);