Re: Kinesis Connector SequenceNumber deserialisation on restart from Savepoint/checkpoint

Posted by on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Kinesis-Connector-SequenceNumber-deserialisation-on-restart-from-Savepoint-checkpoint-tp18616p18617.html

should note this is under 1.4.1

On 2018/02/28 15:38:29, [hidden email] <[hidden email]> wrote:

> 2018-02-28 15:16:36,675 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - class org.apache.flink.streaming.connectors.kinesis.model.SequenceNumber does not contain a setter for field sequenceNumber
> 2018-02-28 15:16:36,675 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - class org.apache.flink.streaming.connectors.kinesis.model.SequenceNumber is not a valid POJO type because not all fields are valid POJO fields.
> 2018-02-28 15:16:36,679 INFO  org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer  - No restore state for FlinkKinesisConsumer.
>
> In an HA setup in AWS EC2, we're getting the above errors when trying to restart a streaming job from either a Savepoint or a Checkpoint (run job, take Savepoint, or let checkpoint be taken, stop and restart).
>
> Any insights on where we can start to look to debug this?
>
> Thanks,
> Dyana
>
>