Hi all, I wanted to use LocalDateTime field in my POJO class used in Flink's pipeline. However when I run the job I can see in the logs following statements:
/class java.time.LocalDateTime does not contain a getter for field date class java.time.LocalDateTime does not contain a setter for field date Class class java.time.LocalDateTime cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance./ I don't see any mention about my POJO type. Does it mean that my class is still being handled by Flink's internal serializer instead of Kryo / other fallback mechanism? Should I be concerned with those logs mentioned above? Flink's version I use is: Apache Flink 1.10.0 for Scala 2.12, and I can see TypeInformation's dedicated to java.time api in the org.apache.flink.api.common.typeinfo.Types in the library itself. Best regards, Oskar -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
