This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch k8s-deploy
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from cbe3fba7b [Improve] FlinkClient instance error issue fixed
add 3872b146f [Improve] job on k8s mode state improvement
No new revisions were added by this update.
Summary of changes:
.../flink/kubernetes/FlinkK8sWatchController.scala | 19 ++-
.../flink/kubernetes/model/ClusterKey.scala | 19 ++-
.../flink/kubernetes/model/JobStatusCV.scala | 2 +-
.../flink/kubernetes/model/K8sEventKey.scala | 16 +-
.../flink/kubernetes/model/TrackId.scala | 4 +-
.../kubernetes/watcher/FlinkJobStatusWatcher.scala | 182 +++++++++++----------
6 files changed, 152 insertions(+), 90 deletions(-)
