diff --git a/pom.xml b/pom.xml
index add9abf1..cbfbcdfd 100755
--- a/pom.xml
+++ b/pom.xml
@@ -102,8 +102,8 @@
4.0.0-SNAPSHOT
- 2.7.0
- 2.7.0
+ 2.8.0-SNAPSHOT
+ 2.8.0-SNAPSHOT
${spring-cloud-stream.version}
diff --git a/spring-cloud-task-samples/partitioned-batch-job/pom.xml b/spring-cloud-task-samples/partitioned-batch-job/pom.xml
index dcdfd617..33387e26 100644
--- a/spring-cloud-task-samples/partitioned-batch-job/pom.xml
+++ b/spring-cloud-task-samples/partitioned-batch-job/pom.xml
@@ -20,7 +20,7 @@
4.0.0-SNAPSHOT
UTF-8
17
- 2.7.0
+ 2.8.0-SNAPSHOT
diff --git a/spring-cloud-task-samples/partitioned-batch-job/src/test/java/org/springframework/cloud/task/partitioner/TaskPartitionerTests.java b/spring-cloud-task-samples/partitioned-batch-job/src/test/java/org/springframework/cloud/task/partitioner/TaskPartitionerTests.java
index 14fb12ad..1450dd58 100644
--- a/spring-cloud-task-samples/partitioned-batch-job/src/test/java/org/springframework/cloud/task/partitioner/TaskPartitionerTests.java
+++ b/spring-cloud-task-samples/partitioned-batch-job/src/test/java/org/springframework/cloud/task/partitioner/TaskPartitionerTests.java
@@ -90,27 +90,27 @@ public class TaskPartitionerTests {
@Test
public void testWithLocalDeployer() throws Exception {
-// SpringApplication app = new SpringApplication(PartitionedBatchJobApplication.class);
-// app.setAdditionalProfiles("master");
-// Properties properties = new Properties();
-// properties.setProperty("spring.datasource.url", DATASOURCE_URL);
-// properties.setProperty("spring.datasource.username", DATASOURCE_USER_NAME);
-// properties.setProperty("spring.datasource.driverClassName", DATASOURCE_DRIVER_CLASS_NAME);
-// properties.setProperty("spring.cloud.deployer.local.use-spring-application-json", "false");
-// app.setDefaultProperties(properties);
-// app.run();
-//
-// Page taskExecutions = this.taskExplorer
-// .findAll(PageRequest.of(0, 10));
-// assertThat(taskExecutions.getTotalElements()).as("Five rows are expected")
-// .isEqualTo(5);
-// assertThat(this.taskExplorer
-// .getTaskExecutionCountByTaskName("PartitionedBatchJobTask"))
-// .as("Only One master is expected").isEqualTo(1);
-// for (TaskExecution taskExecution : taskExecutions) {
-// assertThat(taskExecution.getExitCode()
-// .intValue()).as("return code should be 0").isEqualTo(0);
-// }
+ SpringApplication app = new SpringApplication(PartitionedBatchJobApplication.class);
+ app.setAdditionalProfiles("master");
+ Properties properties = new Properties();
+ properties.setProperty("spring.datasource.url", DATASOURCE_URL);
+ properties.setProperty("spring.datasource.username", DATASOURCE_USER_NAME);
+ properties.setProperty("spring.datasource.driverClassName", DATASOURCE_DRIVER_CLASS_NAME);
+ properties.setProperty("spring.cloud.deployer.local.use-spring-application-json", "false");
+ app.setDefaultProperties(properties);
+ app.run();
+
+ Page taskExecutions = this.taskExplorer
+ .findAll(PageRequest.of(0, 10));
+ assertThat(taskExecutions.getTotalElements()).as("Five rows are expected")
+ .isEqualTo(5);
+ assertThat(this.taskExplorer
+ .getTaskExecutionCountByTaskName("PartitionedBatchJobTask"))
+ .as("Only One master is expected").isEqualTo(1);
+ for (TaskExecution taskExecution : taskExecutions) {
+ assertThat(taskExecution.getExitCode()
+ .intValue()).as("return code should be 0").isEqualTo(0);
+ }
}
@Configuration(proxyBeanMethods = false)
diff --git a/spring-cloud-task-samples/tasksink/pom.xml b/spring-cloud-task-samples/tasksink/pom.xml
index cdd5cfd0..7df19250 100644
--- a/spring-cloud-task-samples/tasksink/pom.xml
+++ b/spring-cloud-task-samples/tasksink/pom.xml
@@ -24,7 +24,7 @@
true
4.0.0-M1
4.0.0-SNAPSHOT
- 2.7.0
+ 2.8.0-SNAPSHOT