This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch k8s-v2
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from 4d750eb8d [Improve] project icon add
add bc970ede2 [Improve] app state watcher bug fixed.
No new revisions were added by this update.
Summary of changes:
.../apache/streampark/common/util/DateUtils.scala | 9 +-
.../apache/streampark/common/util/YarnUtils.scala | 33 +-
.../console/core/watcher/FlinkAppHttpWatcher.java | 637 +++++++++++----------
.../console/core/watcher/FlinkAppLostWatcher.java | 182 ------
.../console/core/watcher/FlinkClusterWatcher.java | 5 +-
.../core/watcher/FlinkK8sChangeEventListener.java | 1 -
6 files changed, 352 insertions(+), 515 deletions(-)
delete mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppLostWatcher.java
