[FLINK-16393] Kinesis consumer unnecessarily creates record emitter thread w/o source sync

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.8.3, 1.9.2, 1.10.0
• Fix Version/s: 1.11.0
• Component/s: Connectors / Kinesis
• Labels: pull-request-available
• Assignee: Thomas Weise
• Reporter: Thomas Weise
• Created: 02/Mar/20 23:20
• Updated: 12/Mar/20 20:00
• Resolved: 04/Mar/20 18:06

Description

The asynchronous record emitter depends on the periodic watermark calculation. If no periodic watermark is configured then records will be directly emitted by the shard consumer threads and the record emitter thread never used. We should skip the thread creation in that case.

Issue Links

• Blocked: FLINK-16573 Kinesis consumer does not properly shutdown RecordFetcher threads
• links to: GitHub Pull Request #11292