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 f9deeccd8e..264bab8b72 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.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 a255037331..12d186f6e2 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 77444ef031..3733615c1a 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.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 ed11425748..dadea616a3 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.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 5b3ee59036..8a57a07a17 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.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 1ebad767ad..14c896fcb4 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.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;