diff --git a/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/BatchExecutionEventTests.java b/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/BatchExecutionEventTests.java
index 7ea7aa33..4cb0594c 100644
--- a/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/BatchExecutionEventTests.java
+++ b/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/BatchExecutionEventTests.java
@@ -316,7 +316,7 @@ public class BatchExecutionEventTests {
 		public void receive(String itemWrite) {
 			Assertions.assertThat(itemWrite).startsWith("3 items ")
 					.as("Message should start with '3 items'");
-			Assertions.assertThat(itemWrite).endsWith("written")
+			Assertions.assertThat(itemWrite).endsWith("written.")
 					.as("Message should end with ' written.'");
 			itemWriteEventsLatch.countDown();
 		}