Hi dachuan, At first glance that does look like a bug. I've opened a pull request with the change here:
https://github.com/apache/incubator-spark/pull/608 Is that the fix you're proposing? Thanks! Andrew On Mon, Feb 17, 2014 at 6:56 AM, dachuan <hdc1...@gmail.com> wrote: > Hi, > > In spark-0.9.0-incubating, Master.scala, line 170 > > logInfo("Registering worker %s:%d with %d cores, %s RAM".format( > host, workerPort, cores, Utils.megabytesToString(memory))) > > might need to be corrected to: > > logInfo("Registering worker %s:%d with %d cores, %s RAM".format( > workerHost, workerPort, cores, Utils.megabytesToString(memory))) >
