lsds / streambench Goto Github PK

Thank you for your hard work with StreamBench. I downloaded and compiled the code by running the YSB with the different frameworks. I was wondering about how to compare the results, since the output format of the various versions with StreamBox, Flink, Saber and Spark is quite different. Do you use some external tool to compare the performance? Any hints to do that?

Many thanks for your help

Gabriele

Hi, there
1)Could you give some advice that how to implement multiply thread to generate source data to Flink?
2)It didn't print the latency value into .out file under taskmanager log, but Throughput info existed. The code couldn't jump into the branch which prevTime not equal to -1. What's more, the WindowedCount value could sink into kafka. I think it will be more convenient to read throughput and latency in local file directly rather than to read from kafka.
Someone may give some suggestion for me? Thanks a ton!