Skip to content

Commit 5b7945f

Browse files
Davidhua1996jefftlin
authored andcommitted
Fix the problem in alerting error message.
1 parent fa91a3f commit 5b7945f

File tree

1 file changed

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

1 file changed

+2
-0
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: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -163,6 +163,8 @@ class TaskMonitorService extends Logging {
163163
var users = jobService.getAlertUsers(job)
164164
if (users == null) {
165165
users = new util.ArrayList[String]()
166+
} else {
167+
users = new util.ArrayList[String](users)
166168
}
167169
users.addAll(util.Arrays.asList(JobConf.STREAMIS_DEVELOPER.getValue.split(","):_*))
168170
users

0 commit comments

Comments
 (0)