Radu Stoian
03/14/2023, 5:18 PMDateTime class that works well in Flink POJOs for efficient serde?
I was using java.time.LocalDateTime but I see that Flink doesn't serde it efficiently, as per the log messages below:
2023-03-14 13:00:02 INFO TypeExtractor - 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.
2023-03-14 13:00:02 INFO TypeExtractor - class java.time.LocalDateTime does not contain a getter for field date
2023-03-14 13:00:02 INFO TypeExtractor - class java.time.LocalDateTime does not contain a getter for field date
2023-03-14 13:00:02 INFO TypeExtractor - class java.time.LocalDateTime does not contain a setter for field date
2023-03-14 13:00:02 INFO TypeExtractor - class java.time.LocalDateTime does not contain a setter for field dateJeremy DeGroot
03/14/2023, 5:28 PMMartijn Visser
03/14/2023, 6:15 PMAnshum Verma
03/15/2023, 9:04 PMRadu Stoian
03/16/2023, 5:13 PM