This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new c58071179 [Improve] Optimize the code structure and merge the util and
utils packages. (#4153)
c58071179 is described below
commit c58071179c31e8a1689ddfcf0d0c8c0d4d1a8fe1
Author: Forus <[email protected]>
AuthorDate: Fri Dec 20 19:37:03 2024 +0800
[Improve] Optimize the code structure and merge the util and utils
packages. (#4153)
---
.../streampark/console/core/component/FlinkCheckpointProcessor.java | 2 +-
.../streampark/console/core/{utils => util}/AlertTemplateUtils.java | 2 +-
.../org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java | 2 +-
.../org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java | 2 +-
.../streampark/console/core/watcher/FlinkK8sChangeEventListener.java | 2 +-
.../org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java | 2 +-
6 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java
index f9deeccd8..264bab8b7 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java
@@ -26,7 +26,7 @@ import
org.apache.streampark.console.core.metrics.flink.CheckPoints;
import org.apache.streampark.console.core.service.SavepointService;
import org.apache.streampark.console.core.service.alert.AlertService;
import
org.apache.streampark.console.core.service.application.FlinkApplicationActionService;
-import org.apache.streampark.console.core.utils.AlertTemplateUtils;
+import org.apache.streampark.console.core.util.AlertTemplateUtils;
import org.apache.streampark.console.core.watcher.FlinkAppHttpWatcher;
import com.github.benmanes.caffeine.cache.Cache;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/utils/AlertTemplateUtils.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/AlertTemplateUtils.java
similarity index 99%
rename from
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/utils/AlertTemplateUtils.java
rename to
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/AlertTemplateUtils.java
index a25503733..12d186f6e 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/utils/AlertTemplateUtils.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/AlertTemplateUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.streampark.console.core.utils;
+package org.apache.streampark.console.core.util;
import org.apache.streampark.common.enums.ClusterState;
import org.apache.streampark.common.util.DateUtils;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
index 77444ef03..3733615c1 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
@@ -42,7 +42,7 @@ import
org.apache.streampark.console.core.service.alert.AlertService;
import
org.apache.streampark.console.core.service.application.FlinkApplicationActionService;
import
org.apache.streampark.console.core.service.application.FlinkApplicationInfoService;
import
org.apache.streampark.console.core.service.application.FlinkApplicationManageService;
-import org.apache.streampark.console.core.utils.AlertTemplateUtils;
+import org.apache.streampark.console.core.util.AlertTemplateUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.hc.client5.http.config.RequestConfig;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
index ed1142574..dadea616a 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
@@ -31,7 +31,7 @@ import
org.apache.streampark.console.core.metrics.yarn.YarnAppInfo;
import org.apache.streampark.console.core.service.FlinkClusterService;
import org.apache.streampark.console.core.service.alert.AlertService;
import
org.apache.streampark.console.core.service.application.FlinkApplicationInfoService;
-import org.apache.streampark.console.core.utils.AlertTemplateUtils;
+import org.apache.streampark.console.core.util.AlertTemplateUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.hadoop.yarn.api.records.YarnApplicationState;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java
index 5b3ee5903..8a57a07a1 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java
@@ -25,7 +25,7 @@ import
org.apache.streampark.console.core.enums.OptionStateEnum;
import org.apache.streampark.console.core.metrics.flink.CheckPoints;
import org.apache.streampark.console.core.service.alert.AlertService;
import
org.apache.streampark.console.core.service.application.FlinkApplicationManageService;
-import org.apache.streampark.console.core.utils.AlertTemplateUtils;
+import org.apache.streampark.console.core.util.AlertTemplateUtils;
import org.apache.streampark.flink.kubernetes.enums.FlinkJobState;
import org.apache.streampark.flink.kubernetes.enums.FlinkK8sDeployMode;
import
org.apache.streampark.flink.kubernetes.event.FlinkClusterMetricChangeEvent;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
index 1ebad767a..14c896fcb 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
@@ -33,7 +33,7 @@ import
org.apache.streampark.console.core.service.alert.AlertService;
import
org.apache.streampark.console.core.service.application.SparkApplicationActionService;
import
org.apache.streampark.console.core.service.application.SparkApplicationInfoService;
import
org.apache.streampark.console.core.service.application.SparkApplicationManageService;
-import org.apache.streampark.console.core.utils.AlertTemplateUtils;
+import org.apache.streampark.console.core.util.AlertTemplateUtils;
import org.apache.flink.annotation.VisibleForTesting;
import org.apache.hadoop.yarn.api.records.FinalApplicationStatus;
