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

StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS

    XMLWordPrintableJSON

Details

    Description

      when StreamElement is reused, we also have to handle tag == TAG_WATERMARK as object reuse disabled do. 

      See also Flink-5017.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              bx123 bx123
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: