Anzhe Meng

Results 2 issues of Anzhe Meng

I think the first two map/reduce process has completed all you need to do. So the last "AggregateReducer" looks like a redundance because it just repeats what the second reducer...

Thank you for this wonderful project. I am getting started with Kafka + Scala, so if I miss anything, please let me know! When I was trying to run your...