<?xml version="1.0" encoding="UTF-8"?>
<job id="myJob" xmlns="http://xmlns.jcp.org/xml/ns/javaee" version="1.0">
    <flow id="flow1" next="step3">
        <step id="step1" next="step2">
            <batchlet ref="myBatchlet1"/>
        </step>
        <step id="step2" >
            <chunk item-count="3">
                <reader ref="myItemReader"/>
                <writer ref="myItemWriter"/>
            </chunk>
        </step>
    </flow>
    <step id="step3" >
        <batchlet ref="myBatchlet2"/>
    </step>
</job>

/META-INF/batch-jobs/myJob.xml

@Deployment
public static WebArchive createDeployment() {
    WebArchive war = ShrinkWrap.create(WebArchive.class)
            .addClass(BatchTestHelper.class)
            .addPackage("org.javaee7.batch.flow")
            .addAsWebInfResource(EmptyAsset.INSTANCE, ArchivePaths.create("beans.xml"))
            .addAsResource("META-INF/batch-jobs/myJob.xml");
    System.out.println(war.toString(true));
    return war;
}

@Test
public void testBatchFlow() throws Exception {
    JobOperator jobOperator = BatchRuntime.getJobOperator();
    Long executionId = jobOperator.start("myJob", new Properties());
    JobExecution jobExecution = jobOperator.getJobExecution(executionId);

    jobExecution = BatchTestHelper.keepTestAlive(jobExecution);

    List<StepExecution> stepExecutions = jobOperator.getStepExecutions(executionId);
    List<String> executedSteps = new ArrayList<>();
    for (StepExecution stepExecution : stepExecutions) {
        executedSteps.add(stepExecution.getStepName());

        if (stepExecution.getStepName().equals("step2")) {
            Map<Metric.MetricType, Long> metricsMap = BatchTestHelper.getMetricsMap(stepExecution.getMetrics());
            System.out.println(metricsMap);
            assertEquals(5L, metricsMap.get(Metric.MetricType.READ_COUNT).longValue());
            assertEquals(5L, metricsMap.get(Metric.MetricType.WRITE_COUNT).longValue());
            assertEquals(5L / 3 + (5 % 3 > 0 ? 1 : 0), metricsMap.get(Metric.MetricType.COMMIT_COUNT).longValue());
        }
    }

    (1)
    assertEquals(3, stepExecutions.size());
    (2)
    assertArrayEquals(new String[]{"step1", "step2", "step3"}, executedSteps.toArray());
    (3)
    assertEquals(BatchStatus.COMPLETED, jobExecution.getBatchStatus());
}