[GitHub] [flink] aljoscha opened a new pull request #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org


With regards,
Apache Git Services