Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 58D0917697 for ; Fri, 15 May 2015 08:25:15 +0000 (UTC) Received: (qmail 20109 invoked by uid 500); 15 May 2015 08:25:15 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 20039 invoked by uid 500); 15 May 2015 08:25:15 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 20027 invoked by uid 99); 15 May 2015 08:25:14 -0000 Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 15 May 2015 08:25:14 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 845EEC50DF for ; Fri, 15 May 2015 08:25:14 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.881 X-Spam-Level: ** X-Spam-Status: No, score=2.881 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id BetP4lV8g_qF for ; Fri, 15 May 2015 08:25:08 +0000 (UTC) Received: from mail-la0-f54.google.com (mail-la0-f54.google.com [209.85.215.54]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 79AFB20514 for ; Fri, 15 May 2015 08:25:07 +0000 (UTC) Received: by laat2 with SMTP id t2so108054139laa.1 for ; Fri, 15 May 2015 01:25:05 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=gYuiycqvR81OiLJqW9x62k1SqClf92TH1fW82YcRXFI=; b=pX9ClfHjt1D0DkOQXmeYRFDBPzC8gtu1AYdxkEfYCbcCZX6dFU41UO+j2GeUPD/UrH fjpp+jgI467sWiwnvcw0I1zi2xaZkaKNMrXDOpS/rWmUSJi9hep4lZeJoEitGCRi+LRI 8HK0Dr5MyklQM4G9oSuFQZeCKxXlqvu8OlINbMdHg6I4QuMFNhGRvULiqoamnEnVgA4I UjttgC+C53HTnbNknzEQQNw9xFZpOX1J1EcX/e6YmQqyO+10NE60Y16tbGHLE5V4qU3g o9ty1hFnKUZI4rJv8WCmobGvdrAmnen3xSGoH9xJAEu4q0omNMEhyMvLqgPSSLlSNIUj gYZw== MIME-Version: 1.0 X-Received: by 10.112.142.232 with SMTP id rz8mr6065630lbb.74.1431678305547; Fri, 15 May 2015 01:25:05 -0700 (PDT) Received: by 10.152.225.171 with HTTP; Fri, 15 May 2015 01:25:05 -0700 (PDT) In-Reply-To: References: Date: Fri, 15 May 2015 10:25:05 +0200 Message-ID: Subject: Re: KryoException with joda Datetime From: Fabian Hueske To: user@flink.apache.org Content-Type: multipart/alternative; boundary=089e0112cdfed5bb2905161a9408 --089e0112cdfed5bb2905161a9408 Content-Type: text/plain; charset=UTF-8 Is there a chance that the version of JodaTime changed? 2015-05-15 10:22 GMT+02:00 Robert Metzger : > 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 > 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 >> 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 < >>> pompermaier@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) >>>> >>> >>> >> >> > --089e0112cdfed5bb2905161a9408 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Is there a chance that the version of JodaTime changed?

2015-05-15= 10:22 GMT+02:00 Robert Metzger <rmetzger@apache.org>:
=
Can you share the Flink pro= gram?
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 <pompermai= er@okkam.it> wrote:
I'm using Flink 0.9-SNAPSHOT and I've never seen this err= or before today (the job haven't changed..)

On Fri, May 15, 2015 at 10:09 AM, R= obert Metzger <rmetzger@apache.org> wrote:
Hi Flavio,

which ver= sion of Flink are you using?
If you are using 0.9 something, then= this should actually work =C2=A0;)=C2=A0

On Fri, May 15, 2015 at 10:= 06 AM, Flavio Pompermaier <pompermaier@okkam.it> wrote:
Hi to all,

this morning I run my Flink job and I got the following exception seri= alizing a DateTime Tuple..could you help me to understand what's happen= ing here?

com.esotericsoftware.kryo.KryoExcep= tion: Class cannot be created (missing no-arg constructor): org.joda.time.c= hrono.ISOChronology
Serialization trace:
iChronology (o= rg.joda.time.DateTime)
at com.esotericsoftware.kryo.Kryo$DefaultInstantiatorStrategy.newInstant= iatorOf(Kryo.java:1228)
at com.esotericsoftware.kryo.Kryo.newInstantiator(Kryo.java:1049)
=
at com.esotericsoftware.k= ryo.Kryo.newInstance(Kryo.java:1058)
at com.esotericsoftware.kryo.serializers.FieldSerializer.c= reateCopy(FieldSerializer.java:620)
at com.esotericsoftware.kryo.serializers.FieldSerializer.co= py(FieldSerializer.java:624)
at com.esotericsoftware.kryo.Kryo.copy(Kryo.java:862)
at com.esotericsoftware.kryo.ser= ializers.ObjectField.copy(ObjectField.java:140)
at com.esotericsoftware.kryo.serializers.FieldS= erializer.copy(FieldSerializer.java:634)
at com.esotericsoftware.kryo.Kryo.copy(Kryo.java:862)<= /div>
at org.apache.flink.= api.java.typeutils.runtime.GenericTypeComparator.setReference(GenericTypeCo= mparator.java:77)
at= org.apache.flink.api.java.typeutils.runtime.GenericTypeComparator.setRefer= ence(GenericTypeComparator.java:1)
at org.apache.flink.api.java.typeutils.runtime.TupleComparat= or.setReference(TupleComparator.java:72)
at org.apache.flink.api.java.typeutils.runtime.TupleCo= mparator.setReference(TupleComparator.java:1)
at org.apache.flink.runtime.util.NonReusingKeyGro= upedIterator.nextKey(NonReusingKeyGroupedIterator.java:115)
at org.apache.flink.runtime.operato= rs.chaining.SynchronousChainedCombineDriver.sortAndCombine(SynchronousChain= edCombineDriver.java:233)
<= /span>at org.apache.flink.runtime.operators.chaining.SynchronousChainedComb= ineDriver.close(SynchronousChainedCombineDriver.java:194)
at org.apache.flink.runtime.operators= .RegularPactTask.run(RegularPactTask.java:504)
at org.apache.flink.runtime.operators.RegularPac= tTask.invoke(RegularPactTask.java:362)
at org.apache.flink.runtime.taskmanager.Task.run(Task.ja= va:562)
at java.lang= .Thread.run(Thread.java:745)



=



--089e0112cdfed5bb2905161a9408--