rua

src/crane/crane_master.go

@@ -372,7 +372,7 @@ func runSpout() {
 	fmt.Println("New job started running...")
 	scanner := bufio.NewScanner(file)
 	for scanner.Scan() {
-		time.Sleep(shared.CraneSpoutInterval)
+		// time.Sleep(shared.CraneSpoutInterval)
 		// activeListMux.Lock()
 		// fmt.Println(activeList)
 		// activeListMux.Unlock()
@@ -383,7 +383,7 @@ func runSpout() {
 		data := Data{ID: child.ID, Tuple: tuple}
 		childServ := child.ServNum
 		fmt.Printf("Send data to bolt %v\n", child.ID)
-		fmt.Println(data)
+		// fmt.Println(data)
 		// fmt.Println("Print children")
 		// fmt.Println(childrenBolts)
 		// fmt.Println(child)