Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19135

(Stream)ExecutionEnvironment.execute() should not throw ExecutionException

    XMLWordPrintableJSON

    Details

      Description

      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().

      We should fix this to go back to the old behaviour.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                aljoscha Aljoscha Krettek
                Reporter:
                aljoscha Aljoscha Krettek
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: