[Improve] Optimize the code structure and merge the util and utils pa…

…ckages. (#4153)
apache · Dec 20, 2024 · c580711 · c580711
1 parent 13ac2c6
commit c580711
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/.../src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java b/.../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/...onsole/core/utils/AlertTemplateUtils.java → ...console/core/util/AlertTemplateUtils.java b/...onsole/core/utils/AlertTemplateUtils.java → ...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/...service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java b/...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/...service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java b/...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/...src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java b/...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/...service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java b/...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;