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
