Khalid Huseynov created ZEPPELIN-1104: -----------------------------------------
Summary: ZeppelinHub storage layer error with large noteboks Key: ZEPPELIN-1104 URL: https://issues.apache.org/jira/browse/ZEPPELIN-1104 Project: Zeppelin Issue Type: Bug Components: zeppelin-zengine Reporter: Khalid Huseynov When using ZeppelinHub storage layer with large notebooks the following exception keeps appearing: ``` WARN [2016-07-04 15:31:34,887] ({WebSocketClient@1872088401-66} Parser.java[notifyWebSocketException]:235) - org.eclipse.jetty.websocket.api.MessageTooLargeException: Text message size [325407] exceeds maximum size [65536] at org.eclipse.jetty.websocket.api.WebSocketPolicy.assertValidTextMessageSize(WebSocketPolicy.java:140) at org.eclipse.jetty.websocket.common.Parser.assertSanePayloadLength(Parser.java:127) at org.eclipse.jetty.websocket.common.Parser.parseFrame(Parser.java:482) at org.eclipse.jetty.websocket.common.Parser.parse(Parser.java:254) at org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.readParse(AbstractWebSocketConnection.java:632) at org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.onFillable(AbstractWebSocketConnection.java:480) at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:544) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555) at java.lang.Thread.run(Thread.java:745) WARN [2016-07-04 15:31:34,887] ({WebSocketClient@1872088401-66} ZeppelinWebsocket.java[onWebSocketError]:57) - Zeppelin socket connection error org.eclipse.jetty.websocket.api.MessageTooLargeException: Text message size [325407] exceeds maximum size [65536] at org.eclipse.jetty.websocket.api.WebSocketPolicy.assertValidTextMessageSize(WebSocketPolicy.java:140) at org.eclipse.jetty.websocket.common.Parser.assertSanePayloadLength(Parser.java:127) at org.eclipse.jetty.websocket.common.Parser.parseFrame(Parser.java:482) at org.eclipse.jetty.websocket.common.Parser.parse(Parser.java:254) at org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.readParse(AbstractWebSocketConnection.java:632) at org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.onFillable(AbstractWebSocketConnection.java:480) at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:544) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555) at java.lang.Thread.run(Thread.java:745) INFO [2016-07-04 15:31:34,888] ({WebSocketClient@1872088401-66} ZeppelinWebsocket.java[onWebSocketClose]:45) - Zeppelin connection closed with code: 1009, message: Text message size [325407] exceeds maximum size [65536] INFO [2016-07-04 15:31:34,916] ({qtp157456214-17} ZeppelinHubRepo.java[save]:178) - ZeppelinHub REST API saving note 2B2XKFCDM INFO [2016-07-04 15:31:34,923] ({qtp157456214-17} NotebookServer.java[onClose]:237) - Closed connection to 127.0.0.1 : 58593. (1006) EOF: Protocol wrong type for socket ERROR [2016-07-04 15:31:34,923] ({qtp157456214-17} NotebookServer.java[broadcast]:330) - socket error org.eclipse.jetty.io.EofException at org.eclipse.jetty.io.ChannelEndPoint.flush(ChannelEndPoint.java:192) at org.eclipse.jetty.io.WriteFlusher.flush(WriteFlusher.java:408) at org.eclipse.jetty.io.WriteFlusher.write(WriteFlusher.java:302) at org.eclipse.jetty.io.AbstractEndPoint.write(AbstractEndPoint.java:129) at org.eclipse.jetty.websocket.common.io.FrameFlusher$Flusher.flush(FrameFlusher.java:152) at org.eclipse.jetty.websocket.common.io.FrameFlusher$Flusher.process(FrameFlusher.java:216) at org.eclipse.jetty.util.IteratingCallback.processing(IteratingCallback.java:246) at org.eclipse.jetty.util.IteratingCallback.iterate(IteratingCallback.java:208) at org.eclipse.jetty.websocket.common.io.FrameFlusher.enqueue(FrameFlusher.java:381) at org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.outgoingFrame(AbstractWebSocketConnection.java:567) at org.eclipse.jetty.websocket.common.extensions.ExtensionStack$Flusher.process(ExtensionStack.java:389) at org.eclipse.jetty.util.IteratingCallback.processing(IteratingCallback.java:246) at org.eclipse.jetty.util.IteratingCallback.iterate(IteratingCallback.java:208) at org.eclipse.jetty.websocket.common.extensions.ExtensionStack.outgoingFrame(ExtensionStack.java:290) at org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.uncheckedSendFrame(WebSocketRemoteEndpoint.java:304) at org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.blockingWrite(WebSocketRemoteEndpoint.java:106) at org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.sendString(WebSocketRemoteEndpoint.java:387) at org.apache.zeppelin.socket.NotebookSocket.send(NotebookSocket.java:69) at org.apache.zeppelin.socket.NotebookServer.broadcast(NotebookServer.java:328) at org.apache.zeppelin.socket.NotebookServer.broadcastNote(NotebookServer.java:440) at org.apache.zeppelin.socket.NotebookServer$ParagraphListenerImpl.afterStatusChange(NotebookServer.java:1201) at org.apache.zeppelin.scheduler.Job.setStatus(Job.java:150) at org.apache.zeppelin.scheduler.RemoteScheduler.submit(RemoteScheduler.java:147) at org.apache.zeppelin.notebook.Note.run(Note.java:464) at org.apache.zeppelin.socket.NotebookServer.runParagraph(NotebookServer.java:1086) at org.apache.zeppelin.socket.NotebookServer.onMessage(NotebookServer.java:181) at org.apache.zeppelin.socket.NotebookSocket.onWebSocketText(NotebookSocket.java:56) at org.eclipse.jetty.websocket.common.events.JettyListenerEventDriver.onTextMessage(JettyListenerEventDriver.java:128) at org.eclipse.jetty.websocket.common.message.SimpleTextMessage.messageComplete(SimpleTextMessage.java:69) at org.eclipse.jetty.websocket.common.events.AbstractEventDriver.appendMessage(AbstractEventDriver.java:65) at org.eclipse.jetty.websocket.common.events.JettyListenerEventDriver.onTextFrame(JettyListenerEventDriver.java:122) at org.eclipse.jetty.websocket.common.events.AbstractEventDriver.incomingFrame(AbstractEventDriver.java:161) at org.eclipse.jetty.websocket.common.WebSocketSession.incomingFrame(WebSocketSession.java:309) at org.eclipse.jetty.websocket.common.extensions.ExtensionStack.incomingFrame(ExtensionStack.java:214) at org.eclipse.jetty.websocket.common.Parser.notifyFrame(Parser.java:220) at org.eclipse.jetty.websocket.common.Parser.parse(Parser.java:258) at org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.readParse(AbstractWebSocketConnection.java:632) at org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection.onFillable(AbstractWebSocketConnection.java:480) at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:544) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.IOException: Protocol wrong type for socket at sun.nio.ch.FileDispatcherImpl.writev0(Native Method) at sun.nio.ch.SocketDispatcher.writev(SocketDispatcher.java:51) at sun.nio.ch.IOUtil.write(IOUtil.java:148) at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:504) at org.eclipse.jetty.io.ChannelEndPoint.flush(ChannelEndPoint.java:172) ``` -- This message was sent by Atlassian JIRA (v6.3.4#6332)