[
https://issues.apache.org/jira/browse/FLINK-12759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-12759:
-------------------------------------
Fix Version/s: (was: 1.9.0)
> 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
> 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)
