George Theodorakis

Thank you for the comment. In the current version, we don't support a unified way of comparing the results and we do it manually. For example, in Flink, we collect...

Hi, 1) You could just change the parallelism and adjust properly the number of records per second. 2) If you redirect worker's output to the .out file, everything will be...

Hi, Unfortunately, I am away in an internship and I don't have much time to look at the code right now. The first thing that you have to keep in...

Hey Tony, this is a follow-up to the questions asked by @chenzongxiong (I've used some parts of his logic to implement my solution). I am trying to implement the YahooBenchmark...

Hi Tony, Thanks for the prompt response and help. You are right about the tumbling window representation. I will add the code/logic from Storm for handling them properly, but this...

Hi Xiaorui, I am not sure I can reproduce your issue with the information you provided. The Docker file was functional the last time I checked it on my laptop....

Hi Xiaorui, Unfortunately, I don't have access to a linux machine and can't reproduce the issue. As for the datasets, you can download them from the following links: i) https://github.com/google/cluster-data/blob/master/ClusterData2011_2.md...