This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch cluster-state
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from 6a9d1d346 Flink cluster state monitoring improve
add 2afc50364 flink rest api watcher improvement
No new revisions were added by this update.
Summary of changes:
.../console/core/annotation/AppUpdated.java | 2 +-
.../console/core/aspect/StreamParkAspect.java | 6 +-
.../core/service/impl/AppBuildPipeServiceImpl.java | 12 ++--
.../core/service/impl/ApplicationServiceImpl.java | 28 ++++-----
.../core/service/impl/ProjectServiceImpl.java | 8 +--
.../core/service/impl/SavePointServiceImpl.java | 10 ++--
.../console/core/task/CheckpointProcessor.java | 4 +-
.../console/core/task/FlinkClusterWatcher.java | 29 +++++-----
...nkRESTAPIWatcher.java => FlinkHttpWatcher.java} | 66 +++++++++-------------
9 files changed, 76 insertions(+), 89 deletions(-)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/{FlinkRESTAPIWatcher.java
=> FlinkHttpWatcher.java} (92%)
