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

Enable check for previous data in SpanningRecordSerializer

    XMLWordPrintableJSON

Details

    Description

      SpanningRecordSerializer only verifies that there is no left-over data from a previous serialization call if SpanningRecordSerializer#CHECKED is true but this is hard-coded as false. Now if there was previous data, we would silently drop this and continue with our data. The deserializer would probably notice and fail but identifying the root cause may not be as easy anymore.

      -> We should enable that check by default since the only thing it does is to verify !java.nio.Buffer#hasRemaining() which cannot be too expensive.

      Attachments

        Activity

          People

            Unassigned Unassigned
            nkruber Nico Kruber
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: