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

NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

    XMLWordPrintableJSON

Details

    Description

      When I use evictor() method to filter the data before a window is triggered, if there is no data that meets the conditions, a nullpointExecption error will be reported.

      This problem occurs in the ReduceApplyWindowFunction.apply method.

      So I think if there is no data to calculate whether it can not trigger the calculation, or judge whether it is null before transmitting the calculation result

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              HunterHunter HunterXHunter
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated: