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).
