![]() ![]() If i combine some process functions(or flatmaps, filters etc.) into one process, then can i solve this issue?. ![]() How does flink decides there is no available resources? (How to calculate max limit).Update: Finally i just found the following error logs from the JobManager This might indicate that the remote task manager was lost.Īt .io.(CreditBasedPartitionRequestClientHandler.java:160) ~Īt .netty4.io.(AbstractChannelHandlerContext.java:262) ~Īt .netty4.io.(AbstractChannelHandlerContext.java:248) ~Īt .netty4.io.(AbstractChannelHandlerContext.java:241) ~Īt .netty4.io.(ChannelInboundHandlerAdapter.java:81) ~Īt .io.(NettyMessageClientDecoderDelegate.java:94) ~Īt .netty4.io.channelInputClosed(ByteToMessageDecoder.java:389) ~Īt .netty4.io.channelInactive(ByteToMessageDecoder.java:354) ~Īt .netty4.io.channelInactive(SslHandler.java:1106) ~Īt .netty4.io.$HeadContext.channelInactive(DefaultChannelPipeline.java:1405) ~Īt .netty4.io.(DefaultChannelPipeline.java:901) ~Īt .netty4.io.$AbstractUnsafe$8.run(AbstractChannel.java:818) ~Īt .netty4.io.safeExecute(AbstractEventExecutor.java:164) ~Īt .netty4.io.runAllTasks(SingleThreadEventExecutor.java:472) ~Īt .netty4.io.run(EpollEventLoop.java:384) ~Īt .netty4.io.$4.run(SingleThreadEventExecutor.java:989) ~Īt .netty4.io.$2.run(ThreadExecutorMap.java:74) ~Īt (Thread.java:829) ~ Here is the log that I found: 21:19:55,891 INFO .executiongraph.ExecutionGraph - Sink: Print to Std. I am using Flink v.1.13.2 with one job manager three task managers.įor some reason (I couldn't find out the reason), task manager connections is being lost.
0 Comments
Leave a Reply. |