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
