diff --git a/src/crane/worker.go b/src/crane/worker.go index d0a36806b7c4f2e546679f9ebb917c313f3e5af5..20e5b9ba11e7fb0c3e05219d72ceff3b9c2eefed 100644 --- a/src/crane/worker.go +++ b/src/crane/worker.go @@ -141,7 +141,7 @@ func processData(data Data) { } //fmt.Println(data.Tuple) processedTuple := boltFunc(data.Tuple) - //fmt.Println(processedTuple) + fmt.Println(processedTuple) newData := Data{ID: 0, Tuple: processedTuple, JobId: data.JobId} // Send the processed data if len(processedTuple) > 0 {