[GitHub] flink pull request #5058: [FLINK-5465] [streaming] Wait for pending timer th...

[aljoscha]

Github user aljoscha commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5058#discussion_r152759896
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
 ---
    @@ -122,6 +123,8 @@
        /** The logger used by the StreamTask and its subclasses. */
        private static final Logger LOG = 
LoggerFactory.getLogger(StreamTask.class);
     
    +   private static final long TIMER_SERVICE_TERMINATION_AWAIT_MS = 7500L;
    --- End diff --
    
    This could be a configuration setting.


---