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