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

Posted to dev@flink.apache.org by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/03 10:15:00 UTC

[jira] [Created] (FLINK-25944) Intermittent Failures on KDF AZP

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)