You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Wong (JIRA)" <ji...@apache.org> on 2019/06/06 08:06:01 UTC
[jira] [Closed] (FLINK-12759) FLInk localmode IN MINICluster can't
drow DAG visualizer plan
[ https://issues.apache.org/jira/browse/FLINK-12759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Wong closed FLINK-12759.
------------------------
Resolution: Not A Bug
> FLInk localmode IN MINICluster can't drow DAG visualizer plan
> -------------------------------------------------------------
>
> Key: FLINK-12759
> URL: https://issues.apache.org/jira/browse/FLINK-12759
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Web Frontend
> Affects Versions: 1.9.0
> Environment: WIN10 4core 16g
> Reporter: Wong
> Priority: Minor
> Fix For: 1.9.0
>
> Attachments: errorsinlocal.png, standalone.png
>
>
> 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]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)