This is an automated email from the ASF dual-hosted git repository.

xxyu pushed a commit to branch kylin5
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit 6f5030377d588d0180e5e050e65e2827ed9b7a03
Author: sibingzhang <74443791+sibingzh...@users.noreply.github.com>
AuthorDate: Tue Jun 13 17:13:50 2023 +0800

    KYLIN-5725 fix open the email notification configuration, to operate job 
and query failed
    
    Co-authored-by: sibing.zhang <sibing.zh...@qq.com>
---
 .../main/java/org/apache/kylin/rest/service/ProjectService.java  | 2 +-
 .../java/org/apache/kylin/rest/service/ProjectServiceTest.java   | 9 +++++++++
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git 
a/src/common-service/src/main/java/org/apache/kylin/rest/service/ProjectService.java
 
b/src/common-service/src/main/java/org/apache/kylin/rest/service/ProjectService.java
index 9bee1b813e..d32d8b261e 100644
--- 
a/src/common-service/src/main/java/org/apache/kylin/rest/service/ProjectService.java
+++ 
b/src/common-service/src/main/java/org/apache/kylin/rest/service/ProjectService.java
@@ -454,7 +454,7 @@ public class ProjectService extends BasicService {
         if (request.getJobStatesNotification() != null) {
             overrideKylinProps.put("kylin.job.notification-enable-states",
                     String.join(",", 
Sets.newHashSet(request.getJobStatesNotification())));
-            overrideKylinProps.put("kylin.job.notification-on-job-error", 
null);
+            overrideKylinProps.put("kylin.job.notification-on-job-error", 
"false");
         } else {
             overrideKylinProps.put("kylin.job.notification-on-job-error",
                     String.valueOf(request.getJobErrorNotificationEnabled()));
diff --git 
a/src/modeling-service/src/test/java/org/apache/kylin/rest/service/ProjectServiceTest.java
 
b/src/modeling-service/src/test/java/org/apache/kylin/rest/service/ProjectServiceTest.java
index 10e665c3c4..029b3c4fda 100644
--- 
a/src/modeling-service/src/test/java/org/apache/kylin/rest/service/ProjectServiceTest.java
+++ 
b/src/modeling-service/src/test/java/org/apache/kylin/rest/service/ProjectServiceTest.java
@@ -378,6 +378,15 @@ public class ProjectServiceTest extends 
NLocalFileMetadataTestCase {
         Assert.assertEquals(3, response.getJobStatesNotification().size());
         Assert.assertFalse(response.isDataLoadEmptyNotificationEnabled());
 
+        val jobNotificationConfigRequest2 = new JobNotificationConfigRequest();
+        
jobNotificationConfigRequest2.setJobStatesNotification(Lists.newArrayList("discarded"));
+        jobNotificationConfigRequest2.setJobErrorNotificationEnabled(true);
+        
jobNotificationConfigRequest2.setJobNotificationEmails(Lists.newArrayList("us...@kyligence.io"));
+        projectService.updateJobNotificationConfig(project, 
jobNotificationConfigRequest2);
+        response = projectService.getProjectConfig(project);
+        Assert.assertEquals(1, response.getJobStatesNotification().size());
+        Assert.assertEquals("discarded", 
response.getJobStatesNotification().get(0));
+
         jobNotificationConfigRequest
                 .setJobNotificationEmails(Lists.newArrayList("@Kylin.io", 
"user2@.io", "us...@kylin.io"));
         thrown.expect(KylinException.class);

Reply via email to