Dawid Wysakowicz created FLINK-10409: ----------------------------------------
Summary: Collection data sink does not propagate exceptions Key: FLINK-10409 URL: https://issues.apache.org/jira/browse/FLINK-10409 Project: Flink Issue Type: Bug Components: Streaming Reporter: Dawid Wysakowicz I would assume that this test should fail with {{RuntimeException}}, but it actually runs just fine. {code} @Test public void testA() throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); List<String> resultList = new ArrayList<>(); SingleOutputStreamOperator<String> result = env.fromElements("A").map(obj -> { throw new RuntimeException(); }); DataStreamUtils.collect(result).forEachRemaining(resultList::add); } {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)