Skip to content

Commit 2e52cac

Browse files
committed
fix compile error
1 parent b87f07a commit 2e52cac

File tree

1 file changed

+0
-20
lines changed

1 file changed

+0
-20
lines changed

linkis-extensions/linkis-et-monitor/src/main/scala/org/apache/linkis/monitor/jobhistory/jobtime/StarrocksTimeExceedRule.scala

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -87,26 +87,6 @@ class StarrocksTimeExceedRule(hitObserver: Observer)
8787
if (taskMinID == 0L || taskMinID > job.getId) {
8888
taskMinID = job.getId
8989
scanRuleList.put("jdbcUnfinishedAlertScan", taskMinID)
90-
// 获取超时kill配置信息
91-
if (StringUtils.isNotBlank(job.getParams)) {
92-
val connectParamsMap = MapUtils.getMap(
93-
datasourceConfMap,
94-
"connectParams",
95-
new util.HashMap[AnyRef, AnyRef]
96-
)
97-
val killTime = MapUtils.getString(connectParamsMap, "kill_task_time", "")
98-
logger.info("starock killTime: {}", killTime)
99-
if (StringUtils.isNotBlank(killTime) && elapse > killTime.toLong * 60 * 1000) {
100-
if (StringUtils.isNotBlank(killTime)) {
101-
val timeoutInSeconds = timeValue.toDouble
102-
val timeoutInMillis = (timeoutInSeconds * 60 * 1000).toLong
103-
if (elapse > timeoutInMillis) {
104-
// 触发kill任务
105-
HttpsUntils.killJob(job)
106-
}
107-
}
108-
}
109-
}
11090
}
11191
case _ =>
11292
logger.warn(

0 commit comments

Comments
 (0)