Alexander Egorov

icon indicating an email [email protected]

icon company Amazon Web Services @aws icon location Austin, TX icon location Principal Streaming Architect at @aws

Results 3 comments of Alexander Egorov

[FLINK-24943][Connectors / Kinesis] Explicitly create KryoSerializer for SequenceNumber class in Kinesis Consumer

> The code changes look good. Recognise that we specify a KryoSerializer instead of making the SequenceNumber a POJO to maintain backwards compatibility. Given that we are changing the state...

[FLINK-24943][Connectors / Kinesis] Explicitly create KryoSerializer for SequenceNumber class in Kinesis Consumer

Does it still make sense to work on merging this change considering [FLINK-30557](https://github.com/apache/flink/pull/21600)?

SequenceNumber class is not POJO type

Hi @dannycranmer here an issue I opened in Apache Flink Jira: https://issues.apache.org/jira/browse/FLINK-24943 I will work on and prepare CR soon.