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

Reply via email to