public FlowSpecification configure() {
return FlowSpecification.Builder.with()
.setName("QueuePartitionFlow")
.setDescription("Flow for testing queue partitioning")
.withFlowlets().add(new StreamReader())
<BUG>.add(new QueuePartitionTestFlowlet())
.add(new QueueBatchTestFlowlet())
.connect().from("StreamReader").to("QueuePartitionTestFlowlet")</BUG>
.from("StreamReader").to("QueueBatchTestFlowlet")
.fromStream("s1").to("StreamReader")

public FlowSpecification configure() {
return FlowSpecification.Builder.with()
.setName("QueuePartitionFlow")
.setDescription("Flow for testing queue partitioning")
.withFlowlets().add(new StreamReader())
.add(new QueuePartitionTestFlowlet(), QueuePartitionTestFlowlet.NUM_INSTANCES)
.add(new QueueBatchTestFlowlet(), QueueBatchTestFlowlet.NUM_INSTANCES)
.connect().from("StreamReader").to("QueuePartitionTestFlowlet")
.from("StreamReader").to("QueueBatchTestFlowlet")
.fromStream("s1").to("StreamReader")
