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

ContinuousProcessingTimeTrigger doesn't fire at the end of the window

    XMLWordPrintableJSON

Details

    Description

       

      srcStream
      .timeWindowAll(Time.seconds(60))
      .trigger(ContinuousProcessingTimeTrigger.of(Time.seconds(10)))...
      

       

       This can correctly calculate the following interval result : 0-10s 10-20s 20-30s 30-40s 40-50s

      But this lost data which was send in 50-60s.

      Because when the first window ends, the time is 59.9999s, it is not equal to window-end-time(60s).So it will not enter the if judgment.

      Attachments

        Activity

          People

            liliwei liwei li
            Gee777 Gee
            Votes:
            0 Vote for this issue
            Watchers:
            8 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: