maxf-decodable opened a new pull request, #3775: URL: https://github.com/apache/flink-cdc/pull/3775
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. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
