You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Thomas Weise (Jira)" <ji...@apache.org> on 2020/03/02 23:21:00 UTC

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

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)