[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224041#comment-15224041
]
ASF GitHub Bot commented on FLINK-3428:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1764#issuecomment-205280465
We still have the issue of the name. I don't like to have "lateness" in the
name, as "lateness" so far refers to either events coming behind watermarks
(nothing to do with watermark generator), or event time being late with respect
to processing time.
In that sense, I still think `BoundedOutOfOrderness` would be a better name.
Other comment: Would be nice to retain a deprecated version of the
`AscendingTimestampExtractor` in its original place (stub that extends to
relocated copy) in order to not break user code.
> Add fixed time trailing timestamp/watermark extractor
> -----------------------------------------------------
>
> Key: FLINK-3428
> URL: https://issues.apache.org/jira/browse/FLINK-3428
> Project: Flink
> Issue Type: Improvement
> Reporter: Robert Metzger
> Assignee: Kostas Kloudas
>
> Flink currently provides only one build-in timestamp extractor, which assumes
> strictly ascending timestamps. In real world use cases, timestamps are almost
> never strictly ascending.
> Therefore, I propose to provide an utility watermark extractor which is
> generating watermarks with a fixed-time trailing.
> The implementation should keep track of the highest event-time seen so far
> and subtract a fixed amount of time from that event time.
> This way, users can for example specify that the watermarks should always
> "lag behind" 10 minutes.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
