Hello,
I am trying to do some benchmark testing with flink streaming. When flink
reads a message in from Kafka, I want to write a timestamp to redis. How
can I modify the existing kafka consumer code to do this? What would be
easiest way to do something like this? Thanks for your help!
Best,
Hi guys,
my job fails on Flink 0.10-snapshot with the following message: Bug in
Hybrid Hash Join: Request to spill a partition with less than two buffers.I
tried to double network buffers but I still got the error :(
Is it a real bug or am I doing something wrong?
See you very soon :)
Flavio
Hi Flavio
This was addressed in Flink-2763. Can you check if you're using the latest
version?
Cheers!
Sachin
On Oct 13, 2015 5:04 AM, "Flavio Pompermaier" wrote:
> Hi guys,
> my job fails on Flink 0.10-snapshot with the following message: Bug in
> Hybrid Hash Join: Request to spill a partition w