This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch issue-3760
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from d2c040c96 [Improve] flink-table-planner dependency improvement
add b52ae5af3 [Improve] flink job deploy improvement
No new revisions were added by this update.
Summary of changes:
.../flink/client/bean/DeployRequest.scala | 3 +-
...tDownRequest.scala => DeployRequestTrait.scala} | 17 +-
.../flink/client/bean/DeployResponse.scala | 4 +-
.../flink/client/bean/ShutDownRequest.scala | 3 +-
.../impl/KubernetesNativeApplicationClient.scala | 31 ++--
.../impl/KubernetesNativeSessionClient.scala | 204 ++++++++-------------
.../streampark/flink/client/impl/LocalClient.scala | 2 +-
.../flink/client/impl/RemoteClient.scala | 96 +++++-----
.../flink/client/impl/YarnApplicationClient.scala | 1 +
.../flink/client/impl/YarnPerJobClient.scala | 3 +-
.../flink/client/impl/YarnSessionClient.scala | 3 +-
.../flink/client/trait/FlinkClientTrait.scala | 100 +++++-----
.../client/trait/KubernetesNativeClientTrait.scala | 21 ++-
.../flink/client/trait/YarnClientTrait.scala | 7 +
.../streampark/flink/core/FlinkClientTrait.scala | 6 +-
15 files changed, 228 insertions(+), 273 deletions(-)
copy
streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/{ShutDownRequest.scala
=> DeployRequestTrait.scala} (80%)
