Hello, does anyone have a `DateTime` class that wo...
# random
r
Hello, does anyone have a
DateTime
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:
Copy code
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 date
j
I usually use Instant
gratitude thank you 1
m
a
Which version of Flink? I have not observed this issue in Flink 1.14 upwards which is in production for more than an year now
r
@Anshum Verma Flink 1.15.2