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)
