[ https://issues.apache.org/jira/browse/FLINK-29326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605843#comment-17605843 ]
Chesnay Schepler commented on FLINK-29326: ------------------------------------------ I would have to assume that the client didn't submit everything based on this line in the logs: {code:java} java.io.IOException: Connection reset by peer {code} > EndOfDataDecoderException observed when uploading a jar > ------------------------------------------------------- > > Key: FLINK-29326 > URL: https://issues.apache.org/jira/browse/FLINK-29326 > Project: Flink > Issue Type: Bug > Components: Runtime / REST > Affects Versions: 1.15.1 > Reporter: Matthias Pohl > Priority: Major > Attachments: jobmanager.log > > > We've observed a {{EndOfDataDecoderException}} in the JobManager when > uploading a jar: > {code} > [2022-09-15 23:55:34,092] WARN File upload failed. > (org.apache.flink.runtime.rest.FileUploadHandler:225) > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.multipart.HttpPostRequestDecoder$EndOfDataDecoderException: > null > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.multipart.HttpPostMultipartRequestDecoder.hasNext(HttpPostMultipartRequestDecoder.java:381) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.multipart.HttpPostRequestDecoder.hasNext(HttpPostRequestDecoder.java:228) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:151) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:69) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:719) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) > [flink-dist-1.15.1.jar:1.15.1] > at java.lang.Thread.run(Thread.java:829) [?:?]{code} -- This message was sent by Atlassian Jira (v8.20.10#820010)