Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6062
Hi @StefanRRichter could I ask one more thing that I'm very interested in?
From this PR I can feel that the `InternalTimerHeap` is really like a
`HeapState` which scoped to the key group(not per key). If we pull this to a
higher level abstraction, it seems that Timer Service is just a type of
`HeapState` that with the de-duplication works, and this seems to also work for
the timer that based on RocksDB. What do you think? Or do you already have any
plan?
---
