Hi KristoffSC,
As far as I know, there is no simple API to let you directly use the
LocalTimeTypeInfo for LocalDataTime in your POJO class. (maybe other guys
know)
If the serializer/deserializer of LocalDataTime is very critical for you
there might be two methods.
1. Using the StreamExecutionEnv
Thanks,
do you have any example how I could use it?
Basically I have a POJO class that has LocalDateTime filed in it.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
g Lee
--
From:KristoffSC
Send Time:2020年3月3日(星期二) 03:47
To:user
Subject:Re: java.time.LocalDateTime in POJO type
Hi Tzu-Li,
I think you misunderstood Oskar's question.
The question was if there are there any plans to support Java'
Hi Tzu-Li,
I think you misunderstood Oskar's question.
The question was if there are there any plans to support Java's
LocalDateTime in Flink's "native" de/serialization mechanism. As we can read
in [1], for basic types, Flink supports all Java primitives and their boxed
form, plus void, String, D
Hi,
What that LOG means (i.e. "must be processed as a Generic Type") is that
Flink will have to fallback to using Kryo for the serialization for that
type.
You should be concerned about that if:
1) That type is being used for some persisted state in snapshots. That would
be the case if you've reg
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 d
