flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows
Date Fri, 15 Jan 2016 15:30:40 GMT
Aljoscha Krettek created FLINK-3243:
---------------------------------------

             Summary: Fix Interplay of TimeCharacteristic and Time Windows
                 Key: FLINK-3243
                 URL: https://issues.apache.org/jira/browse/FLINK-3243
             Project: Flink
          Issue Type: Bug
          Components: Streaming
    Affects Versions: 1.0.0
            Reporter: Aljoscha Krettek
            Assignee: Aljoscha Krettek
            Priority: Blocker


As per the discussion on the Dev ML: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Time-Behavior-in-Streaming-Jobs-Event-time-processing-time-td9616.html.

The discussion seems to have converged on option 2):
- Add dedicated WindowAssigners for processing time and event time
- {{timeWindow()}} and {{timeWindowAll()}} respect the set {{TimeCharacteristic}}. 

This will make the easy stuff easy, i.e. using time windows and quickly switching the time
characteristic. Users will then have the flexibility to mix different kinds of window assigners
in their job.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message