flink kafka question

2015-10-12 Thread Jerry Peng
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,

Bug in Hybrid Hash Join

2015-10-12 Thread Flavio Pompermaier
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

Re: Bug in Hybrid Hash Join

2015-10-12 Thread Sachin Goel
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