@Test
public void testFieldsGroupingOnMultipleSpoutOutputStreams() {

	TopologyBuilder builder = new TopologyBuilder();
	builder.setSpout("spout", new TestDummySpout());
	builder.setBolt("sink", new TestSink()).fieldsGrouping("spout",
			TestDummySpout.spoutStreamId, new Fields("id"));
	FlinkTopology.createTopology(builder);
}