diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregator.java b/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregator.java
index a293d4673..f6e3b86ec 100644
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregator.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregator.java
@@ -16,13 +16,13 @@
 
 package org.springframework.batch.core.partition.support;
 
-import java.util.Collection;
-
 import org.springframework.batch.core.BatchStatus;
 import org.springframework.batch.core.ExitStatus;
 import org.springframework.batch.core.StepExecution;
 import org.springframework.util.Assert;
 
+import java.util.Collection;
+
 /**
  * Convenience class for aggregating a set of {@link StepExecution} instances
  * into a single result.
@@ -53,6 +53,8 @@ public class DefaultStepExecutionAggregator implements StepExecutionAggregator {
 			BatchStatus status = stepExecution.getStatus();
 			result.setStatus(BatchStatus.max(result.getStatus(), status));
 			result.setExitStatus(result.getExitStatus().and(stepExecution.getExitStatus()));
+			result.setFilterCount(result.getFilterCount() + stepExecution.getFilterCount());
+			result.setProcessSkipCount(result.getProcessSkipCount() + stepExecution.getProcessSkipCount());
 			result.setCommitCount(result.getCommitCount() + stepExecution.getCommitCount());
 			result.setRollbackCount(result.getRollbackCount() + stepExecution.getRollbackCount());
 			result.setReadCount(result.getReadCount() + stepExecution.getReadCount());
diff --git a/spring-batch-core/src/test/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregatorTests.java b/spring-batch-core/src/test/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregatorTests.java
index eccb89bd1..32ea0ffb5 100644
--- a/spring-batch-core/src/test/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregatorTests.java
+++ b/spring-batch-core/src/test/java/org/springframework/batch/core/partition/support/DefaultStepExecutionAggregatorTests.java
@@ -15,18 +15,18 @@
  */
 package org.springframework.batch.core.partition.support;
 
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-
-import java.util.Arrays;
-import java.util.Collections;
-
 import org.junit.Test;
 import org.springframework.batch.core.BatchStatus;
 import org.springframework.batch.core.ExitStatus;
 import org.springframework.batch.core.JobExecution;
 import org.springframework.batch.core.StepExecution;
 
+import java.util.Arrays;
+import java.util.Collections;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+
 public class DefaultStepExecutionAggregatorTests {
 
 	private StepExecutionAggregator aggregator = new DefaultStepExecutionAggregator();
@@ -87,10 +87,31 @@ public class DefaultStepExecutionAggregatorTests {
 	}
 
 	@Test
-	public void testAggregateCommitCountSunnyDay() {
-		stepExecution1.setCommitCount(10);
-		stepExecution2.setCommitCount(5);
+	public void testAggregateCountsSunnyDay() {
+		stepExecution1.setCommitCount(1);
+		stepExecution1.setFilterCount(2);
+		stepExecution1.setProcessSkipCount(3);
+		stepExecution1.setReadCount(4);
+		stepExecution1.setReadSkipCount(5);
+		stepExecution1.setRollbackCount(6);
+		stepExecution1.setWriteCount(7);
+		stepExecution1.setWriteSkipCount(8);
+		stepExecution2.setCommitCount(11);
+		stepExecution2.setFilterCount(12);
+		stepExecution2.setProcessSkipCount(13);
+		stepExecution2.setReadCount(14);
+		stepExecution2.setReadSkipCount(15);
+		stepExecution2.setRollbackCount(16);
+		stepExecution2.setWriteCount(17);
+		stepExecution2.setWriteSkipCount(18);
 		aggregator.aggregate(result, Arrays.<StepExecution> asList(stepExecution1, stepExecution2));
-		assertEquals(15, result.getCommitCount());
+		assertEquals(12, result.getCommitCount());
+		assertEquals(14, result.getFilterCount());
+		assertEquals(16, result.getProcessSkipCount());
+		assertEquals(18, result.getReadCount());
+		assertEquals(20, result.getReadSkipCount());
+		assertEquals(22, result.getRollbackCount());
+		assertEquals(24, result.getWriteCount());
+		assertEquals(26, result.getWriteSkipCount());
 	}
 }