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)
>>>
>>
>>
>
>

Reply via email to