[FLINK-12759] FLInk localmode IN MINICluster can't drow DAG visualizer plan

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Not A Bug
• Affects Version/s: 1.9.0
• Component/s: Runtime / Web Frontend

Environment

WIN10 4core 16g

• Assignee: Unassigned
• Reporter: Wong
• Created: 06/Jun/19 03:49
• Updated: 06/Jun/19 12:50
• Resolved: 06/Jun/19 08:05

Description

My plan: {"nodes":[

{"id":1,"type":"Source: fv_can","pact":"Data Source","contents":"Source: fv_can","parallelism":3}

,{"id":2,"type":"CanCodec","pact":"Operator","contents":"CanCodec","parallelism":3,"predecessors":[

{"id":1,"ship_strategy":"FORWARD","side":"second"}

]},{"id":3,"type":"Filter","pact":"Operator","contents":"Filter","parallelism":3,"predecessors":[

{"id":2,"ship_strategy":"FORWARD","side":"second"}

]},{"id":5,"type":"Window(TumblingProcessingTimeWindows(1000), ProcessingTimeTrigger, Can2HbaseBatchFunction)","pact":"Operator","contents":"Window(TumblingProcessingTimeWindows(1000), ProcessingTimeTrigger, Can2HbaseBatchFunction)","parallelism":3,"predecessors":[

{"id":3,"ship_strategy":"HASH","side":"second"}

]},{"id":6,"type":"Can2Redis","pact":"Operator","contents":"Can2Redis","parallelism":3,"predecessors":[

{"id":3,"ship_strategy":"FORWARD","side":"second"}

]},{"id":7,"type":"Filter","pact":"Operator","contents":"Filter","parallelism":3,"predecessors":[

{"id":2,"ship_strategy":"FORWARD","side":"second"}

]},{"id":8,"type":"RUDS","pact":"Operator","contents":"RUDS","parallelism":3,"predecessors":[

{"id":7,"ship_strategy":"FORWARD","side":"second"}

]}]} 

 

 

it was well done on my standalone cluster v1.9-snapshot, but when i debug on localmode it has exceptions:   2019-06-06 11:43:01.283 [flink-rest-server-netty-worker-thread-5] ERROR o.a.flink.runtime.rest.handler.job.JobVertexDetailsHandler - Could not create the handler request.
org.apache.flink.runtime.rest.handler.HandlerRequestException: Cannot resolve path parameter (vertexid) from value "details".
at org.apache.flink.runtime.rest.handler.HandlerRequest.<init>(HandlerRequest.java:71) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:143) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:81) [flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at java.util.Optional.ifPresent(Optional.java:159) ~[na:1.8.0_181]
at org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:44) ~[flink-core-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:78) [flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49) [flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:110) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:89) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:54) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:163) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:67) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_181]
2019-06-06 11:43:01.283 [flink-rest-server-netty-worker-thread-5] ERROR o.a.flink.runtime.rest.handler.job.JobVertexDetailsHandler - Could not create the handler request.
org.apache.flink.runtime.rest.handler.HandlerRequestException: Cannot resolve path parameter (vertexid) from value "details".
at org.apache.flink.runtime.rest.handler.HandlerRequest.<init>(HandlerRequest.java:71) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:143) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:81) [flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at java.util.Optional.ifPresent(Optional.java:159) ~[na:1.8.0_181]
at org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:44) ~[flink-core-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:78) [flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49) [flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:110) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:89) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:54) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:163) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:67) ~[flink-runtime_2.12-1.9-SNAPSHOT.jar:1.9-SNAPSHOT]
at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:656) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]
at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909) ~[flink-shaded-netty-4.1.32.Final-6.0.jar:na]