[FLINK-3081] Kafka Periodic Offset Committer does not properly terminate on canceling

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.10.1
• Fix Version/s: 0.10.2, 1.0.0
• Component/s: Connectors / Kafka
• Assignee: Robert Metzger
• Reporter: Stephan Ewen
• Created: 26/Nov/15 11:11
• Updated: 29/Nov/15 15:17
• Resolved: 29/Nov/15 15:17

Description

The committer is only stopped at the end of the run method. Any termination of the run method via an exception keeps the periodic committer thread running.