diff --git a/spring-batch-core/src/test/java/org/springframework/batch/core/job/builder/FlowJobBuilderTests.java b/spring-batch-core/src/test/java/org/springframework/batch/core/job/builder/FlowJobBuilderTests.java index 860df379c..f59db02cf 100644 --- a/spring-batch-core/src/test/java/org/springframework/batch/core/job/builder/FlowJobBuilderTests.java +++ b/spring-batch-core/src/test/java/org/springframework/batch/core/job/builder/FlowJobBuilderTests.java @@ -139,6 +139,19 @@ public class FlowJobBuilderTests { assertEquals(2, execution.getStepExecutions().size()); } + @Test + public void testBuildSplitUsingStartAndAdd_BATCH_2346() throws Exception { + Flow subflow1 = new FlowBuilder("subflow1").from(step2).end(); + Flow subflow2 = new FlowBuilder("subflow2").from(step3).end(); + Flow splitflow = new FlowBuilder("splitflow").start(subflow1).split(new SimpleAsyncTaskExecutor()) + .add(subflow2).build(); + + FlowJobBuilder builder = new JobBuilder("flow").repository(jobRepository).start(splitflow).end(); + builder.preventRestart().build().execute(execution); + assertEquals(BatchStatus.COMPLETED, execution.getStatus()); + assertEquals(2, execution.getStepExecutions().size()); + } + @Test public void testBuildSplit_BATCH_2282() throws Exception { Flow flow1 = new FlowBuilder("subflow1").from(step1).end();