[
https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627804#comment-14627804
]
ASF GitHub Bot commented on FLINK-1967:
---------------------------------------
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/906#issuecomment-121557154
I could add a mode where the sources don't attach timestamps and where the
StreamRecordSerializer ignores the timestamps and does not multiplex Records
and Watermarks.
What do you mean by sampling the stream and attaching timestamps? If we
want to attach timestamps then the whole machinery for dealing with them needs
to be active anyways.
> 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)
