Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5058#discussion_r152759445
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeService.java
---
@@ -93,4 +94,15 @@
* will result in a hard exception.
*/
public abstract void shutdownService();
+
+ /**
+ * Shuts down and clean up the timer service provider hard and
immediately. This does wait
+ * for all timer to complete or until the time limit is exceeded. Any
call to
--- End diff --
nit: "timers"
---
