Re: Error restoring from savepoint while there's no modification to the job
Yes, I modified ContinuousFileMonitoringFunction to add one more
ListState<Long>. The error might/should have come from that, but I haven't
been able to find out why.
All of my keyed streams are defined by Scala tuples like: /ikeyBy(r =>
(r.customer_id, r.address))/, and the fields using as keys are of types
either String or Long. For this, I don't have to define equals and hashcode
method, do I?
Thanks and best regards,
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/