Aljoscha Krettek created FLINK-19135:
----------------------------------------
Summary: (Stream)ExecutionEnvironment.execute() should not throw
ExecutionException
Key: FLINK-19135
URL: https://issues.apache.org/jira/browse/FLINK-19135
Project: Flink
Issue Type: Improvement
Components: API / DataSet, API / DataStream
Reporter: Aljoscha Krettek
In FLINK-14850 we changed the {{execute()}} method to be basically
{code}
final JobClient jobClient = executeAsync(...);
return jobClient.getJobExecutionResult(userClassloader).get();
{code}
Unfortunately, this means that {{execute()}} now throws an
{{ExecutionException}} instead of a {{ProgramInvocationException}} or
{{JobExecutionException}} as before. The {{ExecutionException}} is wrapping the
other exceptions that we were throwing before.
We didn't notice this in tests because most tests use
{{Test(Stream)Environment}} which overrides the {{execute()}} method and so
doesn't go through the {{PipelineExecutor}} logic or the normal code path of
delegating to {{executeAsync()}}.
We should fix this to go back to the old behaviour.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
