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
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
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
