[Bug] Fix failed to write data to t_message (#4156)

Co-authored-by: Zhiwei Shi <[email protected]>
apache · Jan 8, 2025 · 924fea6 · 924fea6
1 parent 98aa780
commit 924fea6
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/...onsole-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java b/...onsole-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/...ice/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java b/...ice/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