[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611968#comment-14611968 ]
ASF GitHub Bot commented on FLINK-1967: --------------------------------------- Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/879#issuecomment-118037541 Also, when using TaskManagers with 512mb the performance degrades heavily when running successive tests, seems to be related to garbage collection. (On both master and event-time). I will investigate further. > Introduce (Event)time in Streaming > ---------------------------------- > > Key: FLINK-1967 > URL: https://issues.apache.org/jira/browse/FLINK-1967 > Project: Flink > Issue Type: Improvement > Reporter: Aljoscha Krettek > Assignee: Aljoscha Krettek > > This requires introducing a timestamp in streaming record and a change in the > sources to add timestamps to records. This will also introduce punctuations > (or low watermarks) to allow windows to work correctly on unordered, > timestamped input data. In the process of this, the windowing subsystem also > needs to be adapted to use the punctuations. Furthermore, all operators need > to be made aware of punctuations and correctly forward them. Then, a new > operator must be introduced to to allow modification of timestamps. -- This message was sent by Atlassian JIRA (v6.3.4#6332)