flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eric Fukuda <e.s.fuk...@gmail.com>
Subject Yahoo! Streaming Benchmark with Flink
Date Fri, 28 Oct 2016 00:47:11 GMT

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/


View raw message