13/11/08 14:04:32 INFO slf4j.Slf4jEventHandler: Slf4jEventHandler started
13/11/08 14:04:51 INFO worker.Worker: Starting Spark worker jbosstest1:40353 with 2 cores, 512.0 MB RAM
13/11/08 14:04:51 INFO worker.Worker: Spark home: /root/spark-0.8.0-incubating
13/11/08 14:04:56 INFO server.Server: jetty-7.x.y-SNAPSHOT
13/11/08 14:04:56 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/metrics/json,null}
13/11/08 14:04:56 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/static,null}
13/11/08 14:04:56 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/log,null}
13/11/08 14:04:56 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/logPage,null}
13/11/08 14:04:56 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/json,null}
13/11/08 14:04:56 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{*,null}
13/11/08 14:05:04 ERROR worker.Worker: Connection to master failed! Shutting down.
I have set SPARK_MASTER_IP=192.168.50.41 and SPARK_LOCAL_IP on each machine. Yet gives the same error.
[root@jbosstest2 logs]# cat spark-root-org.apache.spark.deploy.worker.Worker-1-jbosstest2.out
Spark Command: java -cp :/root/spark-0.8.0-incubating/conf:/root/spark-0.8.0-incubating/assembly/target/scala-2.9.3/spark-assembly-0.8.0-incubating-hadoop1.0.4.jar -Djava.library.path= -Xms512m -Xmx512m org.apache.spark.deploy.worker.Worker spark://
192.168.50.41:7077========================================
13/11/08 11:28:26 WARN util.Utils: Your hostname, jbosstest2 resolves to a loopback address: 127.0.0.1; using 192.168.50.42 instead (on interface eth0)
13/11/08 11:28:26 WARN util.Utils: Set SPARK_LOCAL_IP if you need to bind to another address
13/11/08 11:28:28 INFO slf4j.Slf4jEventHandler: Slf4jEventHandler started
13/11/08 11:28:28 INFO worker.Worker: Starting Spark worker
192.168.50.42:45953 with 2 cores, 512.0 MB RAM
13/11/08 11:28:28 INFO worker.Worker: Spark home: /root/spark-0.8.0-incubating
13/11/08 11:28:28 INFO server.Server: jetty-7.x.y-SNAPSHOT
13/11/08 11:28:28 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/metrics/json,null}
13/11/08 11:28:28 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/static,null}
13/11/08 11:28:28 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/log,null}
13/11/08 11:28:28 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/logPage,null}
13/11/08 11:28:28 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/json,null}
13/11/08 11:28:28 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{*,null}