[
https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6359:
--------------------------
Description:
In this thread on mailing list:
http://search-hadoop.com/m/Flink/VkLeQPmRa31hd5cw
Gyula Fóra mentioned that timer deletion becomes performance bottleneck due to
the usage of priority queue.
Benjamin has an implementation for Hierarchical Timing Wheels (Apache License) :
https://github.com/ben-manes/caffeine/blob/master/caffeine/src/main/java/com/github/benmanes/caffeine/cache/TimerWheel.java
{code}
* A hierarchical timer wheel to add, remove, and fire expiration events in
amortized O(1) time. The
* expiration events are deferred until the timer is advanced, which is
performed as part of the
* cache's maintenance cycle.
{code}
We should consider porting the above over to facilitate performant timer.
was:
In this thread on mailing list:
http://search-hadoop.com/m/Flink/VkLeQPmRa31hd5cw
Gyula Fóra mentioned that timer deletion becomes performance bottleneck due to
the usage of priority queue.
Benjamin has an implementation for Hierarchical Timing Wheels (Apache License) :
https://github.com/ben-manes/caffeine/blob/master/caffeine/src/main/java/com/github/benmanes/caffeine/cache/TimerWheel.java
{code}
* A hierarchical timer wheel to add, remove, and fire expiration events in
amortized O(1) time. The
* expiration events are deferred until the timer is advanced, which is
performed as part of the
* cache's maintenance cycle.
{code}
We should consider porting the above over to facilitate performant timer.
> Utilize Hierarchical Timing Wheels for performant timer
> -------------------------------------------------------
>
> Key: FLINK-6359
> URL: https://issues.apache.org/jira/browse/FLINK-6359
> Project: Flink
> Issue Type: Improvement
> Components: DataStream API, Local Runtime
> Reporter: Ted Yu
>
> In this thread on mailing list:
> http://search-hadoop.com/m/Flink/VkLeQPmRa31hd5cw
> Gyula Fóra mentioned that timer deletion becomes performance bottleneck due
> to the usage of priority queue.
> Benjamin has an implementation for Hierarchical Timing Wheels (Apache
> License) :
> https://github.com/ben-manes/caffeine/blob/master/caffeine/src/main/java/com/github/benmanes/caffeine/cache/TimerWheel.java
> {code}
> * A hierarchical timer wheel to add, remove, and fire expiration events in
> amortized O(1) time. The
> * expiration events are deferred until the timer is advanced, which is
> performed as part of the
> * cache's maintenance cycle.
> {code}
> We should consider porting the above over to facilitate performant timer.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
