Xuannan Su created FLINK-35089:
----------------------------------

             Summary: Two input AbstractStreamOperator may throw NPE when 
receiving RecordAttributes
                 Key: FLINK-35089
                 URL: https://issues.apache.org/jira/browse/FLINK-35089
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Task
    Affects Versions: 1.19.0
            Reporter: Xuannan Su


Currently the `lastRecordAttributes1` and `lastRecordAttributes2` in the 
`AbstractStreamOperator` are transient. The two fields will be null when it is 
deserialized in TaskManager, which may cause an NPE.

To fix it, we propose to make the RecordAttributes serialization and these 
fields non-transient.

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to