From 4799b8cfa783119f9139e96831b9c0bf8900cfa7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E4=B8=87=E4=B9=89?= Date: Tue, 18 Aug 2026 16:45:54 +0800 Subject: [PATCH] [Fix] Make WebSocket ServerEndpointExporter conditional to avoid ServerContainer not available (#3907) --- .../apache/streampark/console/base/config/WebSocketConfig.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/WebSocketConfig.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/WebSocketConfig.java index 5d33e09f43..d1970aa14c 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/WebSocketConfig.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/WebSocketConfig.java @@ -17,6 +17,7 @@ package org.apache.streampark.console.base.config; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.server.standard.ServerEndpointExporter; @@ -25,6 +26,7 @@ public class WebSocketConfig { @Bean + @ConditionalOnProperty(name = "websocket.enabled", havingValue = "true", matchIfMissing = true) public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); }