[
https://issues.apache.org/jira/browse/FLINK-19135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-19135:
----------------------------------------
Assignee: Aljoscha Krettek
> (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
> Assignee: Aljoscha Krettek
> Priority: Major
>
> 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)
