rua

src/crane/crane_master.go

@@ -384,7 +384,7 @@ func runSpout() {
 		child := childrenBolts[rand.Intn(len(childrenBolts))]
 		data := Data{ID: child.ID, Tuple: tuple}
 		childServ := child.ServNum
-		fmt.Printf("Send data to bolt %v\n", child.ID)
+		// fmt.Printf("Send data to bolt %v\n", child.ID)
 		// fmt.Println(data)
 		// fmt.Println("Print children")
 		// fmt.Println(childrenBolts)
@@ -438,7 +438,7 @@ func handleWorkerConnection(conn net.Conn) {
 			conn.Write([]byte("Ack"))
 
 			// TODO: Process data
-			fmt.Println(*data)
+			// fmt.Println(*data)
 			saveData(data.Tuple)
 		}
 	}