protos37 opened a new pull request #12680:
URL: https://github.com/apache/flink/pull/12680
…bounded preceding functions
## What is the purpose of the change
This fixes a bug in time range bounded preceding functions that the old
records that is no longer required are retracted only if a new record with the
same key comes in. This prevents unlimitedly growing state especially when the
keyspace mutates over time.
## Brief change log
- Register retract timer when new record comes in
- Retract all records when the timer fires and no more record has came in
## Verifying this change
This change is already covered by existing tests, such as `OverWindowITCase`.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths (performance sensitive): yes
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn/Mesos, ZooKeeper: no
- The S3 file system connector: no
## Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? not applicable
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
