flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zentol <...@git.apache.org>
Subject [GitHub] flink pull request #5402: [FLINK-8549] [config] Move TimerServiceOptions int...
Date Fri, 02 Feb 2018 11:38:32 GMT
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)


---

Mime
View raw message