flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: TypeExtractor:1672 - class org.joda.time.DateTime is not a valid POJO type
Date Fri, 20 May 2016 13:27:46 GMT
I think it might just be a warning. When using Kryo it is in the end a
GenericTypeInformation but the TypeAnalyzer might still initially try to
analyze it as a POJO.

On Fri, 20 May 2016 at 12:51 Ufuk Celebi <uce@apache.org> wrote:

> I tried to reproduce this and if you set up the depdency
>
> <dependency>
>        <groupId>de.javakaffee</groupId>
>        <artifactId>kryo-serializers</artifactId>
>        <version>0.28</version>
>    </dependency>
>
> and register the Kryo type as suggested you should not see any log
> messages (e.g. the type should be treated as a generic type and not a
> pojo type).
>
> Does the program successfully execute for you?
>
> – Ufuk
>
>
> On Thu, May 19, 2016 at 5:49 PM, Flavio Pompermaier
> <pompermaier@okkam.it> wrote:
> > Hi to all,
> >
> > I'm using Flink 1.0.2 and testing the job I discovered that I have a lot
> of
> > log with this error:
> >
> > TypeExtractor:1672 - class org.joda.time.DateTime is not a valid POJO
> type
> >
> > initially I though I forgot to properly migrate my code from 0.10.x to
> 1.0.x
> > as stated in [1] but the I checked my code and i correctly build the
> > ExecutionEnvironment as:
> >
> > env = ExecutionEnvironment.createLocalEnvironment(c);
> > env.registerTypeWithKryoSerializer(DateTime.class,
> > JodaDateTimeSerializer.class );
> >
> > So, is this log to ignore or I have a problem? Should it be put to debug
> or
> > not printed at all?
> >
> > [1]
> >
> https://cwiki.apache.org/confluence/display/FLINK/Migration+Guide%3A+0.10.x+to+1.0.x
> >
> > Best,
> > Flavio
>

Mime
View raw message