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/
