Assert.assertEquals(ExecutionMode.CLUSTER_BATCH, bean.getConfig().executionMode);
Assert.assertNotNull(bean.getOrigin());
MySource source = (MySource) bean.getOrigin().getStage();
Assert.assertEquals(ImmutableList.of("S"), source.list);
Assert.assertEquals(1, bean.getPipelineStageBeans().size());
<BUG>PipelineStageBeans stages = bean.getPipelineStageBeans().get(0);
Assert.assertEquals(1, stages.getStages().size());</BUG>
MyTarget target = (MyTarget)stages.getStages().get(0).getStage();
Assert.assertEquals(ImmutableList.of("T"), target.list);
AggregatingMyTarget aggregatingStage = (AggregatingMyTarget) bean.getStatsAggregatorStage().getStage();

Assert.assertEquals(ExecutionMode.CLUSTER_BATCH, bean.getConfig().executionMode);
Assert.assertNotNull(bean.getOrigin());
MySource source = (MySource) bean.getOrigin().getStage();
Assert.assertEquals(ImmutableList.of("S"), source.list);
Assert.assertEquals(1, bean.getPipelineStageBeans().size());
PipelineStageBeans stages = bean.getPipelineStageBeans();
Assert.assertEquals(1, stages.getStages().size());
MyTarget target = (MyTarget)stages.getStages().get(0).getStage();
Assert.assertEquals(ImmutableList.of("T"), target.list);
AggregatingMyTarget aggregatingStage = (AggregatingMyTarget) bean.getStatsAggregatorStage().getStage();
