[FLINK-2523] Make task canceling interrupt interval configurable

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0
• Fix Version/s: 1.0.0
• Component/s: Runtime / Coordination
• Assignee: Kostas Kloudas
• Reporter: Stephan Ewen
• Created: 14/Aug/15 14:52
• Updated: 29/Jan/17 14:42
• Resolved: 14/Mar/16 13:44

Description

When a task is canceled, the cancellation calls periodically "interrupt()" on the task thread, if the task thread does not cancel with a certain time.

Currently, this value is hard coded to 10 seconds. We should make that time configurable.

Until then, I would like to increase the value to 30 seconds, as many tasks (here I am observing it for Kafka consumers) can take longer then 10 seconds for proper cleanup.

Sub-Tasks

• Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.: Resolved