This is an automated email from the ASF dual-hosted git repository. kinghao pushed a commit to branch master-feature in repository https://gitbox.apache.org/repos/asf/linkis.git
commit 2e52cac9567954d469c223c323a56fdb1b6d9c4a Author: kinghao <[email protected]> AuthorDate: Fri Nov 21 23:14:34 2025 +0800 fix compile error --- .../jobhistory/jobtime/StarrocksTimeExceedRule.scala | 20 -------------------- 1 file changed, 20 deletions(-) diff --git a/linkis-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/jobhistory/jobtime/StarrocksTimeExceedRule.scala b/linkis-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/jobhistory/jobtime/StarrocksTimeExceedRule.scala index d1d0820db8..b616c5c02c 100644 --- a/linkis-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/jobhistory/jobtime/StarrocksTimeExceedRule.scala +++ b/linkis-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/jobhistory/jobtime/StarrocksTimeExceedRule.scala @@ -87,26 +87,6 @@ class StarrocksTimeExceedRule(hitObserver: Observer) if (taskMinID == 0L || taskMinID > job.getId) { taskMinID = job.getId scanRuleList.put("jdbcUnfinishedAlertScan", taskMinID) - // 获取超时kill配置信息 - if (StringUtils.isNotBlank(job.getParams)) { - val connectParamsMap = MapUtils.getMap( - datasourceConfMap, - "connectParams", - new util.HashMap[AnyRef, AnyRef] - ) - val killTime = MapUtils.getString(connectParamsMap, "kill_task_time", "") - logger.info("starock killTime: {}", killTime) - if (StringUtils.isNotBlank(killTime) && elapse > killTime.toLong * 60 * 1000) { - if (StringUtils.isNotBlank(killTime)) { - val timeoutInSeconds = timeValue.toDouble - val timeoutInMillis = (timeoutInSeconds * 60 * 1000).toLong - if (elapse > timeoutInMillis) { - // 触发kill任务 - HttpsUntils.killJob(job) - } - } - } - } } case _ => logger.warn( --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
