This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch session-cluster
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from 9ce9830bd [Bug] flink cluster state bug fixed
add 01fca5adf [Improve] job submit parameter Improvement
No new revisions were added by this update.
Summary of changes:
.../core/service/impl/ApplicationServiceImpl.java | 50 ++++++++++++++--------
.../impl/KubernetesNativeApplicationSubmit.scala | 1 -
.../streampark/flink/submit/impl/LocalSubmit.scala | 3 +-
.../flink/submit/impl/RemoteSubmit.scala | 3 +-
.../flink/submit/impl/YarnSessionSubmit.scala | 5 +--
.../submit/trait/KubernetesNativeSubmitTrait.scala | 3 +-
.../flink/submit/trait/YarnSubmitTrait.scala | 2 +-
7 files changed, 37 insertions(+), 30 deletions(-)
