[
https://issues.apache.org/jira/browse/FLINK-10831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-10831.
----------------------------------
Resolution: Duplicate
> Consider making processing time monotonically increasing by default
> -------------------------------------------------------------------
>
> Key: FLINK-10831
> URL: https://issues.apache.org/jira/browse/FLINK-10831
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Task
> Reporter: Andrey Zagrebin
> Priority: Major
>
> At the moment, the processing time is basically implemented in a fixed way as
> System.currentTimeMillis() and not configurable by users.
> The timestamp provided this way is not guaranteed to be monotonically
> increasing. It can jump back for a while because of possible periodic
> synchronisation of local clock with other more accurate system. It can be a
> problem for application business logic if we say that the general notion of
> time is that it always increases.
> We can change SystemProcessingTimeService to emit only timestamp which is not
> less than the latest emitted one, at least for current JVM process.
> This change in behaviour can be also configurable if somebody e.g. relies on
> rather accurate time.
> Other option is that if user needs monotonic processing time then custom
> processing time service should be provided as suggested in FLINK-10830.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
