Job manager 异常信息

Flink 1.11.2 Per Job On Yarn Job manager 报异常 : 这个大概是什么问题。重启之后就没有了。

2020-10-21 16:34:39,657 INFO org.apache.flink.runtime.checkpoint. CheckpointCoordinator [] - Triggering checkpoint 1 (type=CHECKPOINT) @ 1603269279616 for job 3acdf1d32591165ddbf5ef277bfbe260. 2020-10-21 16:34:40,370 INFO org.apache.flink.runtime.checkpoint. CheckpointCoordinator [] - Completed checkpoint 1 for job 3acdf1d32591165ddbf5ef277bfbe260 (53879 bytes in 687 ms). 2020-10-21 16:34:59,621 INFO org.apache.flink.runtime.checkpoint. CheckpointCoordinator [] - Triggering checkpoint 2 (type=CHECKPOINT) @ 1603269299614 for job 3acdf1d32591165ddbf5ef277bfbe260. 2020-10-21 16:34:59,846 INFO org.apache.flink.runtime.checkpoint. CheckpointCoordinator [] - Completed checkpoint 2 for job 3acdf1d32591165ddbf5ef277bfbe260 (53879 bytes in 76 ms). 2020-10-21 16:35:00,764 ERROR org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler [] - error while responding java.nio.file.FileAlreadyExistsException: /tmp/flink-web-492d85b8-f971-45ef -bad7-c00af9d50c35/flink-web-ui/index.html at sun.nio.fs.UnixException.translateToIOException(UnixException.java:88) ~[?:1.8.0_141] at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102) ~[?:1.8.0_141] at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107) ~[?:1.8.0_141] at sun.nio.fs.UnixFileSystemProvider.newByteChannel( UnixFileSystemProvider.java:214) ~[?:1.8.0_141] at java.nio.file.spi.FileSystemProvider.newOutputStream( FileSystemProvider.java:434) ~[?:1.8.0_141] at java.nio.file.Files.newOutputStream(Files.java:216) ~[?:1.8.0_141] at java.nio.file.Files.copy(Files.java:3016) ~[?:1.8.0_141] at org.apache.flink.runtime.rest.handler.legacy.files. StaticFileServerHandler.respondToRequest(StaticFileServerHandler.java:184) ~[flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.handler.legacy.files. StaticFileServerHandler.respondAsLeader(StaticFileServerHandler.java:143) ~[flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler .lambda$channelRead0$0(LeaderRetrievalHandler.java:81) ~[flink-dist_2.11- 1.11.2.jar:1.11.2] at java.util.Optional.ifPresent(Optional.java:159) [?:1.8.0_141] at org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer .java:46) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler .channelRead0(LeaderRetrievalHandler.java:78) [flink-dist_2.11-1.11.2.jar: 1.11.2] at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler .channelRead0(LeaderRetrievalHandler.java:49) [flink-dist_2.11-1.11.2.jar: 1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:374) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:360) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext .java:352) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.handler.router.RouterHandler.routed( RouterHandler.java:110) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.handler.router.RouterHandler .channelRead0(RouterHandler.java:89) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.handler.router.RouterHandler .channelRead0(RouterHandler.java:54) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:374) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:360) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext .java:352) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.handler.codec. MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:374) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:360) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext .java:352) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0( FileUploadHandler.java:174) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0( FileUploadHandler.java:68) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:374) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:360) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext .java:352) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. CombinedChannelDuplexHandler$DelegatingChannelHandlerContext .fireChannelRead(CombinedChannelDuplexHandler.java:438) [flink-dist_2.11- 1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.handler.codec. ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:328) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.handler.codec. ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:302) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java: 253) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:374) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:360) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext .java:352) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java: 1421) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:374) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:360) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel. DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel.nio. AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop .processSelectedKey(NioEventLoop.java:697) [flink-dist_2.11-1.11.2.jar:1.11. 2] at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop .processSelectedKeysOptimized(NioEventLoop.java:632) [flink-dist_2.11-1.11.2 .jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop .processSelectedKeys(NioEventLoop.java:549) [flink-dist_2.11-1.11.2.jar:1.11 .2] at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run( NioEventLoop.java:511) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.util.concurrent. SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918) [flink-dist_2.11-1.11.2.jar:1.11.2] at org.apache.flink.shaded.netty4.io.netty.util.internal. ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [flink-dist_2.11-1.11.2 .jar:1.11.2] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] 2020-10-21 16:35:19,621 INFO org.apache.flink.runtime.checkpoint. CheckpointCoordinator [] - Triggering checkpoint 3 (type=CHECKPOINT) @ 1603269319614 for job 3acdf1d32591165ddbf5ef277bfbe260. 2020-10-21 16:35:19,873 INFO org.apache.flink.runtime.checkpoint. CheckpointCoordinator [] - Completed checkpoint 3 for job 3acdf1d32591165ddbf5ef277bfbe260 (53879 bytes in 83 ms).*来自志愿者整理的flink