X-Git-Url: http://plrg.eecs.uci.edu/git/?a=blobdiff_plain;f=Robust%2Fsrc%2FBenchmarks%2FMapReduce%2FJava%2FJobClient.java;h=cab79af503bc050307dbde54a8f6656a9dd23305;hb=4cb63e913202459da4fe9d01feb7c02f1b98dd6f;hp=b45f77e6e8178a42fa8f2695a0dc91da1a91c570;hpb=81ecd0677d631eac7ecb1dfd4ef6c12da9a79ab5;p=IRC.git

diff --git a/Robust/src/Benchmarks/MapReduce/Java/JobClient.java b/Robust/src/Benchmarks/MapReduce/Java/JobClient.java
index b45f77e6..cab79af5 100644
--- a/Robust/src/Benchmarks/MapReduce/Java/JobClient.java
+++ b/Robust/src/Benchmarks/MapReduce/Java/JobClient.java
@@ -9,11 +9,11 @@ public class JobClient{
 	Master master = new Master(conf.getM(), conf.getR(), splitter);
 	
 	// split input file
-	System.printString("Split\n");
+	//System.printString("Split\n");
 	master.split();
 	
 	// do 'map'
-	System.printString("Map\n");
+	//System.printString("Map\n");
 	MapWorker[] mworkers = master.assignMap();
 	for(int i = 0; i < mworkers.length; ++i) {
 	    MapWorker mworker = mworkers[i];
@@ -23,7 +23,7 @@ public class JobClient{
 	}
 	
 	// register intermediate output from map workers to master
-	System.printString("Mapoutput\n");
+	//System.printString("Mapoutput\n");
 	for(int i = 0; i < mworkers.length; ++i) {
 	    for(int j = 0; j < conf.getR(); ++j) {
 		String temp = mworkers[i].outputFile(j);
@@ -36,7 +36,7 @@ public class JobClient{
 	//assert(master.isMapFinish());
 	
 	// do 'reduce'
-	System.printString("Reduce\n");
+	//System.printString("Reduce\n");
 	ReduceWorker[] rworkers = master.assignReduce();
 	for(int i = 0; i < rworkers.length; ++i) {
 	    ReduceWorker rworker = rworkers[i];
@@ -46,7 +46,7 @@ public class JobClient{
 	}
 	
 	// merge all the intermediate output from reduce workers to master
-	System.printString("Merge\n");
+	//System.printString("Merge\n");
 	for(int i = 0; i < rworkers.length; ++i) {
 	    master.collectROutput(rworkers[i].getOutputFile());
 	    master.setReduceFinish(rworkers[i].getID());