From 40b984050608f0e00847bb4647abc18f70e63c78 Mon Sep 17 00:00:00 2001 From: Glenn Renfro Date: Fri, 11 Mar 2022 09:57:50 -0500 Subject: [PATCH] Updated Deployer Version to 2.8 Reactivated tests for rempote partition --- pom.xml | 4 +- .../partitioned-batch-job/pom.xml | 2 +- .../partitioner/TaskPartitionerTests.java | 42 +++++++++---------- spring-cloud-task-samples/tasksink/pom.xml | 2 +- 4 files changed, 25 insertions(+), 25 deletions(-) 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