【Flink】Flink network netty ProducerFailedException SimpleChannelInboundHandler NullPointerException

    技术2024-04-01  89

    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
    Processed: 0.014, SQL: 10