aljoscha opened a new pull request #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820 ## What is the purpose of the change This introduces `Pipeline` as a new common base class of `Plan` (DataSet API) and `StreamGraph` (DataStream API). Then we add `PlanTranslationUtil` which can translate a `Pipeline` to a `JobGraph` for use in the `flink-clients` package. As a last step we change the different environments to all use the `PlanExecutor` abstraction which internally uses the `PipelineTranslationUtil`. ## Brief change log The commits messages also clearly outline the changes and describe the rationale behind the changes, so looking at them one after the other would be easiest. The changes are roughly: - Add common base interface `Pipeline` - Add translation util - Use translation util in the executors - Use PlanExecutors in the streaming environments ## Verifying this change This is mostly covered by existing tests but we add specific unit tests for the new translation utils. ## Documentation Only Javadocs, because there are no user-facing changes yet.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
