So do you think you could release a path soon? I need it to continue my work..otherwise if it's very simple you could send me the snippet of code to change my local flink version ;)
Best, Flavio On Fri, May 15, 2015 at 11:22 AM, Robert Metzger <rmetz...@apache.org> wrote: > Yes ;) > > On Fri, May 15, 2015 at 11:10 AM, Flavio Pompermaier <pomperma...@okkam.it > > wrote: > >> Do you think it's comething easy to fix..? >> >> On Fri, May 15, 2015 at 10:51 AM, Robert Metzger <rmetz...@apache.org> >> wrote: >> >>> No problem ;) >>> >>> I was able to reproduce the issue and filed a JIRA for it: >>> https://issues.apache.org/jira/browse/FLINK-2019 >>> >>> On Fri, May 15, 2015 at 10:36 AM, Flavio Pompermaier < >>> pomperma...@okkam.it> wrote: >>> >>>> 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) >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>> >>>>>>> >>>>>> >>>> >>> >> >
