Skip to content

Commit d8e9f9f

Browse files
committed
Avoid the duplicate alert message.
1 parent 6c18e79 commit d8e9f9f

File tree

1 file changed

+1
-1
lines changed
  • streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/service

1 file changed

+1
-1
lines changed

streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/service/TaskMonitorService.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ class TaskMonitorService extends Logging {
111111
// 连续三次还是出现异常,说明Linkis的Manager已经不能正常提供服务,告警并不再尝试获取状态,等待下次尝试
112112
val users = getAlertUsers(job)
113113
users.add(job.getCreateBy)
114-
alert(jobService.getAlertLevel(job), s"请求LinkisManager失败,Linkis集群出现异常,请关注!影响任务:[${job.getName}],请联系用户[${job.getSubmitUser}]进行处理!", users, streamTask)
114+
alert(jobService.getAlertLevel(job), s"请求LinkisManager失败,Linkis集群出现异常,请关注!影响任务:[${job.getName}]", users, streamTask)
115115
}
116116
}
117117
streamTaskMapper.updateTask(streamTask)

0 commit comments

Comments
 (0)