@Test
public void testFieldsGroupingOnMultipleBoltOutputStreams() {

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