test

src/crane/crane_master.go

@@ -53,6 +53,8 @@ var spoutInput string
 var craneOutput string
 var fd *os.File
 
+var debugCount int
+
 // ---- end spout var definitions ----
 
 // StartMaster - Master starts here
@@ -66,6 +68,7 @@ func StartMaster() {
 
 // InitializeCraneMaster - initialize the master
 func InitializeCraneMaster() {
+	debugCount = 0
 	fd = nil
 	needRestart = false
 	isWorking = false
@@ -439,7 +442,11 @@ func handleWorkerConnection(conn net.Conn) {
 
 			// TODO: Process data
 			// fmt.Println(*data)
-			saveData(data.Tuple)
+			debugCount += 1
+			if debugCount%10000 == 0 {
+				fmt.Println(debugCount)
+			}
+			//saveData(data.Tuple)
 		}
 	}
 	conn.Close()