Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5962#discussion_r188004528
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SystemProcessingTimeService.java
---
@@ -197,6 +204,23 @@ public boolean shutdownAndAwaitPending(long time,
TimeUnit timeUnit) throws Inte
return timerService.awaitTermination(time, timeUnit);
}
+ @Override
+ public boolean shutdownServiceUninterruptible(long timeoutMs) {
--- End diff --
Do we want to make the shutdown of the timer service swallow the
`InterruptedException` also for all subsequent calls happening after the
shutdown of the timer service?
---
