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)

Reply via email to