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

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

              Dates

                Created:
                Updated:
                Resolved: