Hi,
I'm trying to benchmark Flink without Kafka as mentioned in this post (
http://data-artisans.com/extending-the-yahoo-streaming-benchmark/). After
running flink.benchmark.state.AdvertisingTopologyFlinkState with
user.local.event.generator in localConf.yaml set to 1, I ran
flink.benchmark.utils.
the AnaylzeTool is for processing logs of a different benchmark.
>>
>> CC Jamie and Robert who worked on the benchmark.
>>
>> On Wed, Aug 24, 2016 at 3:25 AM, Eric Fukuda
>> wrote:
>> > Hi,
>> >
>> > I'm tryin
.
>
> Regards,
> Robert
>
> On Wed, Aug 24, 2016 at 10:32 PM, Eric Fukuda
> wrote:
>
>> Hi Max, Robert,
>>
>> Thanks for the advice. I'm trying to build the "performance" project, but
>> failing with the following error. Is there a s
use cases.
>
> Regards,
> Robert
>
>
> On Fri, Sep 2, 2016 at 5:09 PM, Eric Fukuda wrote:
>
>> Hi Robert,
>>
>> I've been trying to build the "performance" project using various
>> versions of Flink, but failing. It seems that I need both
&
it.
>
> Can you try this commit: df42160832ff65ae2a85b478d1dd0b398fa6ef3f ?
>
> I actually believe its probably easier to just pick the classes you need
> from the "benchmark" repository and fit them to the current code base.
>
> On Fri, Sep 2, 2016 at 9:12 PM, Eric
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 ab
> I hope this answers your questions.
>
> Cheers,
> Till
>
> On Fri, Oct 28, 2016 at 2:47 AM, Eric Fukuda wrote:
>
>> Hi,
>>
>> I have two questions on the blog post on Yahoo! Streaming Benchmark with
>> Flink [1].
>>
>> First is abou
