Re: Streaming issue help needed

Hello Vaidya, The error message is talking about the class "AbstractTime", which was removed long ago (before 1.0). Could you please double check that the Flink version is set appropriately everywhere, and that the binaries running in the cluster are really 1.1.2? Best, Gábor 2016-09-15 11:52

Re: Streaming issue help needed

Dear Marton, Thanks very much for taking time to look into this issue. Actually I am on latest Flink version (1.1.2). Would the Hadoop version might be causing the problem (it is 2.6 with CDH 5.5.1)? Would appreciate any more pointers to resolve this. Thanks, Vaidya. > On 14-Sep-2016, at 4

Re: Streaming issue help needed

Dear Vaidya, This seems weird, me guess is that somehow that Time and AbstractTime implementations are not from the same Flink version. According to your Maven build you should be using Flink 0.10.2. Since then there have been changes to windowing, are you tied to that version or would it be feas

Streaming issue help needed

Hi, I am trying to implement Flink steaming using an example in GitHub: https://github.com/andi1400/bestXStreamRating . While executing I am getting the below error. Can you please help guide me on the resolution. Thanks in advance! Starting