You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Qishang <zh...@gmail.com> on 2020/10/21 09:17:40 UTC
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).
Re:Job manager 异常信息
Posted by hailongwang <18...@163.com>.
Hi Qishang,
我看异常之后，又有checkpoint成功的日志 `Completed checkpoint 3 for job`，
所以这个异常应该是对任务没影响，可能只是前端请求时，服务端没有相应的结果返回而已。
Best,
Hailong Wang
At 2020-10-21 16:17:40, "Qishang" <zh...@gmail.com> wrote:
>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).