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
Hi all,
I am using Flink with Bahir's Apache ActiveMQ connector. However it's quite
dated and poses many limitations, most notably the source supports only
ByteMessages, does not support parallelism and has a bug that is only fixed
in a snapshot version.
So I started implementing my own
