@Test(expected = IllegalArgumentException.class)
public void testInvalidSource() throws Exception {

    Source src = new StreamlineSource(Collections.singleton(new Stream("f1", "f2")));
    Sink sink = new StreamlineSink();
    Processor processor = new StreamlineProcessor(Collections.singleton(new Stream("r1")));
    topology.addEdge(src, processor);
}