Re: Flink error;

2020-05-09 Thread Sivaprasanna S
It is working as expected. If I'm right, the print operator will simply call the `.toString()` on the input element. If you want to visualize your payload in JSON format, override the toString() in `SensorData` class with the code to form your payload as a JSON representation using ObjectMapper or

Re: upgrade flink from 1.9.1 to 1.10.0 on EMR

2020-05-09 Thread aj
Hello Yang, I have attached my pom file and I did not see that I am using any Hadoop dependency. Can you please help me. On Wed, May 6, 2020 at 1:22 PM Yang Wang wrote: > Hi aj, > > From the logs you have provided, the hadoop version is still 2.4.1. > Could you check the user jar(i.e. events-pr