Commits on Sep 8, 2020

1. [FLINK-19135] Strip ExecutionException in (Stream)ExecutionEnvironmen… …

   …t.execute()
   
   In FLINK-14850 we changed the execute() method to be basically
   
   final JobClient jobClient = executeAsync(...);
   return jobClient.getJobExecutionResult(userClassloader).get();
   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().
   
   This change brings us back to the previous behaviour.

   

   aljoscha committed Sep 8, 2020
   Configuration menu

   • View commit details
   • Copy full SHA for 0b67901
   • Browse repository at this point

   Copy the full SHA

   0b67901 View commit details

   Browse the repository at this point in the history