(incubator-streampark) branch dev updated: [Bug] Fix failed to write data to t_message (#4156)

[benjobs]

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

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 924fea65d [Bug] Fix failed to write data to t_message (#4156)
924fea65d is described below

commit 924fea65def91fc78c6b030d74f43f4314913dc7
Author: Happy-shi <1900022...@pku.edu.cn>
AuthorDate: Thu Jan 9 00:24:21 2025 +0800

    [Bug] Fix failed to write data to t_message (#4156)
    
    Co-authored-by: Zhiwei Shi <sh...@rd.netease.com>
---
 .../org/apache/streampark/console/core/enums/NoticeTypeEnum.java  | 3 +++
 .../streampark/console/core/service/impl/MessageServiceImpl.java  | 8 ++++++--
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java
index 952051e65..d68e60aef 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java
@@ -17,6 +17,8 @@
 
 package org.apache.streampark.console.core.enums;
 
+import com.baomidou.mybatisplus.annotation.EnumValue;
+
 import java.util.Arrays;
 
 /** notification type */
@@ -27,6 +29,7 @@ public enum NoticeTypeEnum {
     /** message */
     MESSAGE(2);
 
+    @EnumValue
     private final int value;
 
     public int get() {
diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java
index e1aac54b1..563de2b44 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java
@@ -41,8 +41,12 @@ public class MessageServiceImpl extends 
ServiceImpl<MessageMapper, Message>
 
     @Override
     public void push(Message message) {
-        save(message);
-        WebSocketEndpoint.pushNotice(message);
+        try {
+            save(message);
+            WebSocketEndpoint.pushNotice(message);
+        } catch (Exception e) {
+            log.error("Error pushing notice: {}", e.getMessage(), e);
+        }
     }
 
     @Override