1.背景
一个flink程序报错这个
org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Error at remote task manager
'1.datanode3/72.118.1.15:39701'.
at org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler.decodeMsgCreditBasedPartitionRequestClientHandler.java:280
)
at org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler.channelRead
(CreditBasedPartitionRequestClientHandler.java:175
)
at org.apache.flink.shaded.netty4.io.net