Github user bowenli86 closed the pull request at:
https://github.com/apache/flink/pull/5236
---
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5236#discussion_r159465985
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -442,23 +458,15 @@ public int
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5236#discussion_r159465653
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -442,23 +458,15 @@ public int
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5236#discussion_r159464428
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -475,4 +483,38 @@ public int
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5236#discussion_r159462006
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -262,16 +277,17 @@ public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5236#discussion_r159461777
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -442,23 +458,15 @@ public int
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5236
[FLINK-8322] support getting number of existing timers in TimerService
## What is the purpose of the change
There are pretty common use cases where users want to use timers as
