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

Windowed fold operation fails because the initial value was not serialized

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.10.0
    • 0.10.0
    • None
    • None

    Description

      The windowed fold operation currently fails because the initial value was not serialized. The reason for this is that the fold operation is realized as a WindowFunction within an AbstractUdfStreamOperator and does not get the output type information forwarded (which is necessary for the serialization).

      The solution is to let the AbstractUdfStreamOperator forward the output type information to the WindowFunction if it implements the OutputTypeConfigurable interface.

      Attachments

        Activity

          People

            trohrmann Till Rohrmann
            trohrmann Till Rohrmann
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: