Re: Apache Flink Operator State as Query Cache

Thanks for the answer. Currently the approach that i'm using right now is creating a base/marker interface to stream different type of message to the same operator. Not sure about the performance hit about this compare to the CoFlatMap function. Basically this one is providing query cache, so

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

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.

finite subset of an infinite data stream

Hello, I need to extract a finite subset like a data buffer from an infinite data stream. The best way for me is to obtain a finite stream with data accumulated for a 1minute before (as example). But I not found any existing technique to do it. As a possible ways how to do something near to

Re: Flink on EC"

Sorry for Confusing, the flink cluster throws following stack trace.. org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Failed to submit job 29a2a25d49aa0706588ccdb8b7e81c6c (Flink Java Job at Sun Nov 08 18:50:52 UTC 2015) at

Re: Flink on EC"

HI Fabian, thanks for reply. I use a karamel receipt to install flink on ec2.Currently I am using flink-0.9.1-bin-hadoop24.tgz . In that file the NativeS3FileSystem is included. First I’ve tried it with the