Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/4380
@fhueske
I have updated the PR.
Based on the previous discussions i have:
1) integrated the support for offset and fetch when time is ascending as
you suggested (having a counter within the process function that will restrict
the output)
2) add back the implementation for offset and fetch with retraction and
bind this for queries that would have time descending. It is important to
remark that the way i intended to enable this behavior is that at every new
time unit the offset/fetch restriction will be reapplied from scratch. That
means that in an example such as (getting the first 2 elements):
t1: event 1, event 2, event 3 => output is event 1 and event 2
t2: event 4 => output is retract (events 1&2) emit event 4
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
