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

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                Gee777 Gee
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated: