@Test(expected = IllegalArgumentException.class)
public void testUndeclared() {

	final FlinkOutputFieldsDeclarer declarer = new FlinkOutputFieldsDeclarer();
	declarer.getOutputType("unknownStreamId");
}