Unfortunately it's really difficult for me to extract the code..I'm using joda shipped with Flink 0.9-SNAPSHOT (i.e. 2.5) and before today I've never seen this error..als o because DateTime is Serializable :)
On Fri, May 15, 2015 at 10:25 AM, Fabian Hueske <fhue...@gmail.com> wrote: > Is there a chance that the version of JodaTime changed? > > 2015-05-15 10:22 GMT+02:00 Robert Metzger <rmetz...@apache.org>: > >> Can you share the Flink program? >> Or at least the definition of the Tuple? >> >> I'll look into this issue in a few minutes. >> >> On Fri, May 15, 2015 at 10:13 AM, Flavio Pompermaier < >> pomperma...@okkam.it> wrote: >> >>> I'm using Flink 0.9-SNAPSHOT and I've never seen this error before today >>> (the job haven't changed..) >>> >>> On Fri, May 15, 2015 at 10:09 AM, Robert Metzger <rmetz...@apache.org> >>> wrote: >>> >>>> Hi Flavio, >>>> >>>> which version of Flink are you using? >>>> If you are using 0.9 something, then this should actually work ;) >>>> >>>> On Fri, May 15, 2015 at 10:06 AM, Flavio Pompermaier < >>>> pomperma...@okkam.it> wrote: >>>> >>>>> Hi to all, >>>>> >>>>> this morning I run my Flink job and I got the following exception >>>>> serializing a DateTime Tuple..could you help me to understand what's >>>>> happening here? >>>>> >>>>> com.esotericsoftware.kryo.KryoException: Class cannot be created >>>>> (missing no-arg constructor): org.joda.time.chrono.ISOChronology >>>>> Serialization trace: >>>>> iChronology (org.joda.time.DateTime) >>>>> at >>>>> com.esotericsoftware.kryo.Kryo$DefaultInstantiatorStrategy.newInstantiatorOf(Kryo.java:1228) >>>>> at com.esotericsoftware.kryo.Kryo.newInstantiator(Kryo.java:1049) >>>>> at com.esotericsoftware.kryo.Kryo.newInstance(Kryo.java:1058) >>>>> at >>>>> com.esotericsoftware.kryo.serializers.FieldSerializer.createCopy(FieldSerializer.java:620) >>>>> at >>>>> com.esotericsoftware.kryo.serializers.FieldSerializer.copy(FieldSerializer.java:624) >>>>> at com.esotericsoftware.kryo.Kryo.copy(Kryo.java:862) >>>>> at >>>>> com.esotericsoftware.kryo.serializers.ObjectField.copy(ObjectField.java:140) >>>>> at >>>>> com.esotericsoftware.kryo.serializers.FieldSerializer.copy(FieldSerializer.java:634) >>>>> at com.esotericsoftware.kryo.Kryo.copy(Kryo.java:862) >>>>> at >>>>> org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator.setReference(GenericTypeComparator.java:77) >>>>> at >>>>> org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator.setReference(GenericTypeComparator.java:1) >>>>> at >>>>> org.apache.flink.api.java.typeutils.runtime.TupleComparator.setReference(TupleComparator.java:72) >>>>> at >>>>> org.apache.flink.api.java.typeutils.runtime.TupleComparator.setReference(TupleComparator.java:1) >>>>> at >>>>> org.apache.flink.runtime.util.NonReusingKeyGroupedIterator.nextKey(NonReusingKeyGroupedIterator.java:115) >>>>> at >>>>> org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver.sortAndCombine(SynchronousChainedCombineDriver.java:233) >>>>> at >>>>> org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver.close(SynchronousChainedCombineDriver.java:194) >>>>> at >>>>> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:504) >>>>> at >>>>> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) >>>>> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) >>>>> at java.lang.Thread.run(Thread.java:745) >>>>> >>>> >>>> >>> >>> >>
