[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Error restoring from savepoint while there's no modification to the job

Hi Kostas,

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/