[Optimization][Flink] FLINK StreamexEcuitionenvalonment needs to execute the PIPELINE method

[zackyoungh]

Search before asking

• I had searched in the issues and found no similar optimization requirement.

Description

当需要执行批算子 plan 计划时，无法直接调用方法，而 executeAsync(StreamGraph streamGraph)去又是可以直接调用Pipeline类。
这边就需要重构一下 StreamexEcuitionenvalonment 类。以下是2种建议：

1. 继承 StreamexEcuitionenvalonment ，flink-client每个模块重写
2. 自定义 DinkyStreamexEcuitionenvalonment ，使其执行器和 flink 类单独隔离开来

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[github-actions]

Hello @zackyoungh, this issue is about CDC/CDCSOURCE, so I assign it to @aiwenmo. If you have any questions, you can comment and reply.

你好 @zackyoungh, 这个 issue 是关于 CDC/CDCSOURCE 的，所以我把它分配给了 @aiwenmo。如有任何问题，可以评论回复。