@Test(expected = RuntimeException.class)
public void testUndeclaredStream() {

	TopologyBuilder builder = new TopologyBuilder();
	builder.setSpout("spout", new TestSpout());
	builder.setBolt("bolt", new TestBolt()).shuffleGrouping("spout");
	FlinkTopology.createTopology(builder);
}