diff --git a/src/crane/crane_master.go b/src/crane/crane_master.go index 4410b27d9c575c7ecbd82a795a4ef32b55e571a4..c3b21c337415e24a4468bffe85e18fce67e347de 100644 --- a/src/crane/crane_master.go +++ b/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()