This is an automated email from the ASF dual-hosted git repository. zjffdu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/master by this push: new 37b072a [ZEPPELIN-5343] Zeppelin Interface becomes unresponsive 37b072a is described below commit 37b072a83e3444a7d6aecc2d253749e832e24ad7 Author: Jeff Zhang <zjf...@apache.org> AuthorDate: Tue May 11 10:28:23 2021 +0800 [ZEPPELIN-5343] Zeppelin Interface becomes unresponsive ### What is this PR for? This is experimental PR for fixing the zeppelin unresponsive issue. Regarding the jstack, it seems blocked in `NotebookSocket#send` method, this PR change it from sync call to async call. ### What type of PR is it? [Bug Fix ] ### Todos * [ ] - Task ### What is the Jira issue? * https://issues.apache.org/jira/browse/ZEPPELIN-5343 ### How should this be tested? * CI ### Screenshots (if appropriate) ### Questions: * Does the licenses files need update? No * Is there breaking changes for older versions? No * Does this needs documentation? No Author: Jeff Zhang <zjf...@apache.org> Closes #4113 from zjffdu/ZEPPELIN-5343 and squashes the following commits: 8a155af67 [Jeff Zhang] [ZEPPELIN-5343] Zepplin Interface becomes unresponsive --- .../src/main/java/org/apache/zeppelin/socket/NotebookSocket.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/zeppelin-server/src/main/java/org/apache/zeppelin/socket/NotebookSocket.java b/zeppelin-server/src/main/java/org/apache/zeppelin/socket/NotebookSocket.java index d69be98..613a7c9 100644 --- a/zeppelin-server/src/main/java/org/apache/zeppelin/socket/NotebookSocket.java +++ b/zeppelin-server/src/main/java/org/apache/zeppelin/socket/NotebookSocket.java @@ -67,7 +67,7 @@ public class NotebookSocket extends WebSocketAdapter { } public synchronized void send(String serializeMessage) throws IOException { - connection.getRemote().sendString(serializeMessage); + connection.getRemote().sendStringByFuture(serializeMessage); } public String getUser() {