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)