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 <lvhu...@gmail.com> 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, > Averell > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
