diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/TaskExecutorPartitionHandler.java b/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/TaskExecutorPartitionHandler.java
index a15478039..ff0cf8021 100644
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/TaskExecutorPartitionHandler.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/partition/support/TaskExecutorPartitionHandler.java
@@ -63,11 +63,7 @@ public class TaskExecutorPartitionHandler implements PartitionHandler, Initializ
 			});
 
 			try {
-				taskExecutor.execute(new Runnable() {
-					public void run() {
-						task.run();
-					}
-				});
+				taskExecutor.execute(task);
 				tasks.add(task);
 			}
 			catch (TaskRejectedException e) {