NullPointer in Flink OperatorChain pushToOperator

Question

我正在编写一个使用kafka 的flink应用程序

FlinkKafkaConsumer<MyPojo> consumer = new FlinkKafkaConsumer(TOPIC, new MyPojoDes(), prop)
StreamExecutionEnvironment env = new StreamExecutionEnvironment ();
env.addSource(consumer).print();

在高级上，这个应用程序使用kafka主题中的消息并打印它。但当我运行它时，我会得到低于异常的消息

由java.lang.NullPointerException引起：null网址：org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:577(在org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:554(网址：org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:534(网址：org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collection(AbstractStreamOperator.java:718(

我尝试对代码进行调试，发现OperatorChain类中有一个序列化程序变量，该变量为null，不确定的原因

Answer 1

我发现在反序列化程序中调试时，我返回的是null而不是实际类型信息，因此OperatorChain中的序列化程序变量为null。

public TypeInformation<MyPojo> getProducerdType()
{
//return null
return TypeInformationOf(MyPojo.class);
}