-
Type:
Improvement
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.5.0
-
Fix Version/s: 1.6.0
-
Component/s: None
-
Labels:None
The current data structures in the `HeapInternalTimerService` are not able to support efficient timer deletes, the complexity is currently O(n), where n is the number of registered timers.
We can keep track of timer's positions in the priority queue and (in combination with the already existing set/map) have a more efficient algorithm for deletes.
- is depended upon by
-
FLINK-9440 Allow cancelation and reset of timers
-
- Closed
-
- links to