Code optimization

WeDataSphere · Oct 29, 2024 · 3440db9 · 3440db9
1 parent 97b494a
commit 3440db9
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 10 deletions.
diff --git a/...inkis-et-monitor/src/main/java/org/apache/linkis/monitor/scheduled/JobHistoryMonitor.java b/...inkis-et-monitor/src/main/java/org/apache/linkis/monitor/scheduled/JobHistoryMonitor.java
@@ -206,14 +206,14 @@ public void jobHistoryUnfinishedScan() {
       logger.info("[INFO] Loaded 0 alerts jobtime alert-rule from alert properties file.");
     } else {
       logger.info(
-              "[INFO] Loaded {} alerts jobtime alert-rules from alert properties file.",
-              jobTimeAlerts.size());
+          "[INFO] Loaded {} alerts jobtime alert-rules from alert properties file.",
+          jobTimeAlerts.size());
       shouldStart = true;
       JobMonitorUtils.addIntervalToImsAlerts(jobTimeAlerts, realIntervals);
       JobTimeExceedRule jobTimeExceedRule =
-              new JobTimeExceedRule(
-                      jobTimeAlerts.keySet(), new JobTimeExceedAlertSender(jobTimeAlerts));
-            scanner.addScanRule(jobTimeExceedRule);
+          new JobTimeExceedRule(
+              jobTimeAlerts.keySet(), new JobTimeExceedAlertSender(jobTimeAlerts));
+      scanner.addScanRule(jobTimeExceedRule);
     }
     StarrocksTimeExceedRule starrocksTimeExceedRule =
         new StarrocksTimeExceedRule(new StarrocksTimeExceedAlterSender());

diff --git a/...linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/client/MonitorHTTPClient.scala b/...linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/client/MonitorHTTPClient.scala
@@ -17,12 +17,23 @@
 
 package org.apache.linkis.monitor.client
 
-import org.apache.linkis.datasource.client.response.{GetConnectParamsByDataSourceNameResult, GetInfoByDataSourceNameResult, GetInfoPublishedByDataSourceNameResult}
+import org.apache.linkis.datasource.client.response.{
+  GetConnectParamsByDataSourceNameResult,
+  GetInfoByDataSourceNameResult,
+  GetInfoPublishedByDataSourceNameResult
+}
 import org.apache.linkis.httpclient.authentication.AuthenticationStrategy
 import org.apache.linkis.httpclient.dws.authentication.StaticAuthenticationStrategy
 import org.apache.linkis.httpclient.dws.config.{DWSClientConfig, DWSClientConfigBuilder}
 import org.apache.linkis.httpclient.response.Result
-import org.apache.linkis.monitor.request.{DataSourceParamsAction, EmsListAction, EntranceTaskAction, KeyvalueAction, KillJobAction, MonitorAction}
+import org.apache.linkis.monitor.request.{
+  DataSourceParamsAction,
+  EmsListAction,
+  EntranceTaskAction,
+  KeyvalueAction,
+  KillJobAction,
+  MonitorAction
+}
 import org.apache.linkis.monitor.response.{EntranceTaskResult, KeyvalueResult, KillJobResultAction}
 import org.apache.linkis.ujes.client.response.EmsListResult
 

diff --git a/...cements/linkis-udf-service/src/main/scala/org/apache/linkis/udf/api/rpc/UdfReceiver.scala b/...cements/linkis-udf-service/src/main/scala/org/apache/linkis/udf/api/rpc/UdfReceiver.scala
@@ -25,14 +25,11 @@ import org.apache.linkis.udf.entity.{PythonModuleInfo, PythonModuleInfoVO}
 import org.apache.linkis.udf.service.{PythonModuleInfoService, UDFService, UDFTreeService}
 
 import org.apache.commons.beanutils.BeanUtils
-import org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo.Bean
-import org.apache.htrace.fasterxml.jackson.databind.util.BeanUtil
 
 import java.{lang, util}
 
 import scala.collection.JavaConverters.asScalaBufferConverter
 import scala.concurrent.duration.Duration
-import scala.tools.nsc.interactive.Logger
 
 class UdfReceiver extends Receiver with Logging {