Re: local debug Scala

This issue occurs when Flink has been build against another major scala release. Did you build Flink yourself or download it from somewhere (maven central) ? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/local-debug-Scala-tp1764p3481.html S

Re: Creating a Source using an Akka actor

Hi Hector, I'm sorry that nobody replied to your message so far. I think you are not subscribed to the user@flink.apache.org mailing list when you posted this question. Therefore, we Flink community didn't receive your message. To subscribe, send an email to user-subscr...@flink.apache.org. Regar

Re: Flink execution time benchmark.

Hi Saleh, I'm sorry that nobody replied to your message. I think you were not subscribed to the user@flink.apache.org. mailing list when you posted this question. Therefore, we Flink community didn't receive your message. Did you resolve the issue in the meantime or are you still seeking for help?

Re: Not enough buffers when running Flink jar on cluster

Hi, the number of required buffers depends a lot on the job. If a job needs to send data to operators running on other machines, it needs buffers to do that. Operations like reduce or join usually need many buffers. If you just have a bunch of chained mappers, the requirements are lower. Increasi