Thomas Weise created FLINK-16393:
------------------------------------
Summary: Kinesis consumer unnecessarily creates record emitter
thread w/o source sync
Key: FLINK-16393
URL: https://issues.apache.org/jira/browse/FLINK-16393
Project: Flink
Issue Type: Bug
Components: Connectors / Kinesis
Affects Versions: 1.10.0, 1.9.2, 1.8.3
Reporter: Thomas Weise
Assignee: Thomas Weise
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
