diff --git a/src/crane/worker.go b/src/crane/worker.go index 170f523fda5dc3c82e44b06620fb6bf87008847e..bd7172d2594043f5f175c85cc63a35ae8637cba4 100644 --- a/src/crane/worker.go +++ b/src/crane/worker.go @@ -175,7 +175,7 @@ func sendProcessedData(tuple []interface{}, bolt BoltInfo) { servNum := child.ServNum // Send data port := strconv.Itoa(shared.CraneWorkerPort) - sendDataToWorker(data, servNum) + sendDataToWorker(data, servNum, port) } } }