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] With regards, Apache Git Services
