osdir.com


[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.

{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)