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

Posted to issues@flink.apache.org by "Ying Xu (Jira)" <ji...@apache.org> on 2019/12/17 17:42:00 UTC

[jira] [Created] (FLINK-15301) Flink Kinesis AsyncRecordEmitter needs to handle unchecked exception gracefully

Ying Xu created FLINK-15301:
-------------------------------

             Summary: Flink Kinesis AsyncRecordEmitter needs to handle unchecked exception gracefully
                 Key: FLINK-15301
                 URL: https://issues.apache.org/jira/browse/FLINK-15301
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kinesis
            Reporter: Ying Xu


Currently, any runTime exception encountered inside the `AsyncRecordEmitter.emitRecordAndUpdateState()` function could cause the thread to exit silently. Flink job would continue to run, but the stopped record emitter would subsequently cause Kinesis data consumption to stall. 

 

The AsyncRecordEmitter need to catch unchecked exception, log errors, and perhaps trigger job restart subsequently. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)