[jira] [Created] (FLINK-10409) Collection data sink does not propagate exceptions

[Shang Yuanchun (Jira)]

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)