Dear Hawin,
As for your issues with running the Flink Kafka examples: are those
resolved with Aljoscha's comment in the other thread? :)
Best,
Marton
On Fri, Jun 26, 2015 at 8:40 AM, Hawin Jiang wrote:
> Hi Stephan
>
> Yes, that is a great idea. if it is possible, I will try my best to
> co
Hi everyone,
Mihail and I have now solved the issue.
The exception was caused because the array size in question was read from a
static field of the enclosing class, inside an anonymous mapper. Making the
mapper a standalone class and passing the array size to the constructor
solved the issue.
W
