Re: Error restoring from savepoint while there's no modification to the job
You restore your job with the custom source from a savepoint taken without the custom source?
> On Oct 10, 2018, at 11:34 AM, Averell <lvhuyen@xxxxxxxxx> wrote:
> 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/