[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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

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.

	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();



This message was sent by Atlassian JIRA