You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@streampark.apache.org by be...@apache.org on 2024/01/15 04:43:38 UTC

(incubator-streampark) branch k8s-deploy updated (cbe3fba7b -> 3872b146f)

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(-)