Yahoo! Streaming Benchmark with Flink

Posted by Eric Fukuda on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Yahoo-Streaming-Benchmark-with-Flink-tp9768.html

Hi,

I have two questions on the blog post on Yahoo! Streaming Benchmark with Flink [1].

First is about the join operation to associate ad_ids and campaign_ids. In flink.benchmark.state.AdvertisingTopologyFlinkStateHighKeyCard, I don't see this being done. Is there a reason for this?

Second is about Akka actor. Reading flink.benchmark.state.QueryableWindowOperator or flink.benchmark.state.QueryableWindowOperatorEvicting, it looks like the Akka actor is being prepared but not used in the actual processing (processElement()). Is this correct? And how do I enable Akka in the job?

[1] http://data-artisans.com/extending-the-yahoo-streaming-benchmark/

Thanks,

Eric