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

Agile BoardRank to TopRank to BottomAttach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskConvert to sub-taskLinkCloneLabelsUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            HunterHunter HunterHunter

            Dates

              Created:
              Updated:

              Issue deployment