NetworkWordCount Tests

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

NetworkWordCount Tests

eduardocalfaia
Hi Guys,

I am doing some test with NetworkWordCount scala code where I am counting and summing a stream of words received from network  using foreach action, thanks TD. Firstly I have began with this scenario 1 Master + 1 Worker(also actioning like Stream source) and I have obtained the result(bellow).  The worker machine has 4GB RAM e 2 Core, I am trying to understand why some results are equals zero. I have seen that RAM Memory goes down very quickly.
Could anyone help me this question? 

Thanks Guys

308425
964276
628731
801010
711439
808223
507143
981999
853862
852054
581291
1078153
822553
860385
907984
792155
801966
860747
804655
827498
727398
834044
821059
708479
949565
796239
813312
717552
792051
811995
803358
762467
838375
803473
773933
824912
811991
605851
1012426
631953
725137
747702
907284
0
0
0
0
0
0
113534
1591325
861635
857057
815570
287201
0
0

Informativa sulla Privacy: http://www.unibs.it/node/8155