Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-35089

Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes

    XMLWordPrintableJSON

Details

    Description

      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 will initialize the two fields in the setup method.

       

      Attachments

        Issue Links

          Activity

            People

              xuannan Xuannan Su
              xuannan Xuannan Su
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: