Zichen Liu created FLINK-25944:
----------------------------------
Summary: Intermittent Failures on KDF AZP
Key: FLINK-25944
URL: https://issues.apache.org/jira/browse/FLINK-25944
Project: Flink
Issue Type: New Feature
Components: Connectors / Kinesis
Reporter: Zichen Liu
Assignee: Ahmed Hamdy
Fix For: 1.15.0
AsyncSinkWriter implements snapshotState to write the pending request into
state but none of the implementation (Kinesis, Firehose) provides a state
serializer nor interacts with the recovered state.
* Implement
{code:java}
getWriterStateSerializer{code}
for the Kinesis/Firehose Sinks
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
