[jira] [Created] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException

[Shang Yuanchun (Jira)]

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)