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

The example of sliding windows with offset in documentation is not correct

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • Documentation
    • None

    Description

      In documentation of windows, we have the following example code:

      // sliding processing-time windows offset by -8 hours
      input
          .keyBy(<key selector>)
          .window(SlidingProcessingTimeWindows.of(Time.hours(12), Time.hours(1), Time.hours(-8)))
          .<windowed transformation>(<window function>);
      

      Unfortunately, it will raise as the absolute value of offset must be less than the slide.

      Attachments

        Activity

          People

            Weijie Guo Weijie Guo
            Weijie Guo Weijie Guo
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: