diff --git a/linkis-extensions/linkis-et-monitor/src/main/java/org/apache/linkis/monitor/scheduled/JobHistoryMonitor.java b/linkis-extensions/linkis-et-monitor/src/main/java/org/apache/linkis/monitor/scheduled/JobHistoryMonitor.java index cd66bd9795..712ae62899 100644 --- a/linkis-extensions/linkis-et-monitor/src/main/java/org/apache/linkis/monitor/scheduled/JobHistoryMonitor.java +++ b/linkis-extensions/linkis-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-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/client/MonitorHTTPClient.scala b/linkis-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/client/MonitorHTTPClient.scala index b3021f9b52..6b76fd3c73 100644 --- a/linkis-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/client/MonitorHTTPClient.scala +++ b/linkis-extensions/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/linkis-public-enhancements/linkis-udf-service/src/main/scala/org/apache/linkis/udf/api/rpc/UdfReceiver.scala b/linkis-public-enhancements/linkis-udf-service/src/main/scala/org/apache/linkis/udf/api/rpc/UdfReceiver.scala index 0ed5143353..bc69bfb943 100644 --- a/linkis-public-enhancements/linkis-udf-service/src/main/scala/org/apache/linkis/udf/api/rpc/UdfReceiver.scala +++ b/linkis-public-enhancements/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 {