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

flink sql support window with alignment

    XMLWordPrintableJSON

Details

    Description

      for now, sql: 

      // code placeholder
      SELECT  COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
      

      not supported in flink sql, when rowtime is processTime, the window is  assigned by UTC time,  it is not correct day window when i was in specified time zone.

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            zhaoshijie zzsmdfj
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: