Hi Ahmed,
I tried setting up your use case and for me it all seems to work. However,
I didn't use the Spring framework and executed the program in a local Flink
cluster.
Maybe you can compile a self-containing example (including example data) to
reproduce your problem and send it to us.
Cheers,
Hello Flavio,
Thank you so much for replying, however I didn't download Flink locally, I
only added dependencies in a maven project. So i don't think I'll be able
to modify the KryoSerializer class. But yeah me too i think it's the
problem.
Thanks,
Ahmed
On 8 June 2016 at 16:07, Flavio Pompermaier
Hello Till,
Thanks so much for your reply. Here's my program:
So that's TwitterSource:
public class TwitterSource extends Stream {
private static final long serialVersionUID = 1L;
protected transient BlockingQueue queue;
protected int queueSize = 1;
private transient BasicClie
Hi Ahmed,
I also have the same error that is probably caused by the KryoSerializer.
Right now I'm testing a patch to this problem so maybe you could also test
it. Unfortunately I'm using Flink 1.0.2 so I don't know whether you can use
my KryoSerializer but I think so. Actually I just recreate Input
Hi Ahmed,
the problem usually occurs, if you use differently initialized Kryo
instances where one instance has a different set of classes registered. But
your data could also be corrupted because you see an
IndexOutOfBoundsException where you try to access an element of an array
with size 0 at ind
