[FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Flink CDC
• Labels: Flink-CDC pull-request-available
• Assignee: Unassigned
• Reporter: Max Feng
• Created: 03/Dec/24 22:28
• Updated: 15/Dec/24 20:07

Description

As a user of the FlinkPipelineComposer API, I would like to run jobs with a pre-configured StreamExecutionEnvironment of my choosing, for commonality with executing non-Flink-CDC jobs. However, the API only allows me to pass a Configuration object, which FlinkPipelineComposer uses to build its own StreamExecutionEnvironment.

In addition, I would like to retrieve a JobClient from submitted jobs, again for commonality with non-Flink-CDC jobs.

Issue Links

• links to: GitHub Pull Request #3775