[
https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662178#comment-16662178
]
ASF GitHub Bot commented on FLINK-10543:
----------------------------------------
hequn8128 opened a new pull request #6918: [FLINK-10543][table] Leverage
efficient timer deletion in relational operators
URL: https://github.com/apache/flink/pull/6918
## What is the purpose of the change
[FLINK-9423](https://issues.apache.org/jira/browse/FLINK-9423) added support
for efficient timer deletions. This feature is available since Flink 1.6 and
should be used by the relational operator of SQL and Table API.
This pr leverage deleting timers to make timer control more efficient.
## Brief change log
- Delete expired timer for relational operator of SQL and Table API such
as GROUP BY/ OVER/JOIN.
- As for non-window join, use one timer state and leverage min and max
retention time when udpate timer state. We can delete all state once for all in
this way.
- Update Tests according to the timer changes.
## Verifying this change
This change is already covered by existing tests, such as:
- All over and group by tests.
- JoinITCase and JoinHarnessTest.
## 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): (no)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: (no)
- The S3 file system connector: (no)
## Documentation
- Does this pull request introduce a new feature? (no)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> Leverage efficient timer deletion in relational operators
> ---------------------------------------------------------
>
> Key: FLINK-10543
> URL: https://issues.apache.org/jira/browse/FLINK-10543
> Project: Flink
> Issue Type: Improvement
> Components: Table API & SQL
> Reporter: Fabian Hueske
> Assignee: Hequn Cheng
> Priority: Minor
> Labels: pull-request-available
>
> FLINK-9423 added support for efficient timer deletions. This feature is
> available since Flink 1.6 and should be used by the relational operator of
> SQL and Table API.
> Currently, we use a few workarounds to handle situations when deleting timers
> would be the better solution.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
