Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5402#discussion_r165623427 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -206,6 +206,14 @@ key("task.cancellation.timeout") .defaultValue(180000L); + /** + * This configures how long we wait for the timers to finish all pending timer threads + * when the stream task is cancelled . + */ + public static final ConfigOption<Long> TASK_CANCELLATION_TIMEOUT_TIMERS = ConfigOptions + .key("task.cancellation.timeout.timers") + .defaultValue(7500L); --- End diff -- add deprecated key? (I'm not quite sure whether the previous option was part of a release)
---