giraph-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andro Bermúdez Serrano <andro.bermu...@gmail.com>
Subject Re: Problem running the PageRank example in a cluster
Date Thu, 24 Oct 2013 18:55:33 GMT
I commented the line:
127.0.1.1   name
in /etc/hosts and the example run without problems.




2013/10/21, Andro Bermúdez Serrano <andro.bermudez@gmail.com>:
> this is the output of the command in all servers:
>
> Chain INPUT (policy ACCEPT)
> target     prot opt source               destination
> ACCEPT     tcp  --  anywhere             anywhere             state
> NEW tcp dpts:30000:30010
> ACCEPT     tcp  --  anywhere             anywhere             state
> NEW tcp dpt:22181
>
> Chain FORWARD (policy ACCEPT)
> target     prot opt source               destination
>
> Chain OUTPUT (policy ACCEPT)
> target     prot opt source               destination
>
> 2013/10/21, Simon McGloin <simonmcgloin@gmail.com>:
>> Are you sure the iptables rules were applied to all your servers? If you
>> run the command
>> sudo iptables -L
>> does it show the ports as open?
>>
>>
>> On Mon, Oct 21, 2013 at 8:16 PM, Andro Bermúdez Serrano <
>> andro.bermudez@gmail.com> wrote:
>>
>>> I added this two lines:
>>>
>>> iptables -A INPUT -p tcp -m state --state NEW -m tcp --dport
>>> 30000:30010 -j ACCEPT
>>> iptables -A INPUT -p tcp -m state --state NEW -m tcp --dport 22181 -j
>>> ACCEPT
>>>
>>> I ran the example and the error persists.
>>>
>>>
>>> 2013/10/21, Claudio Martella <claudio.martella@gmail.com>:
>>> > Yes, that would be the reason. In addition to the ports for netty, you
>>> also
>>> > need to accept connections to Zookeeper (e.g. 22181).
>>> >
>>> >
>>> > On Mon, Oct 21, 2013 at 5:06 PM, Simon McGloin
>>> > <simonmcgloin@gmail.com>wrote:
>>> >
>>> >> Hey Andro,
>>> >> I believe the reason you are seeing this error is due to ports being
>>> >> blocked by iptables. You need to have port 30000 open for the master
>>> >> on
>>> >> all
>>> >> machines in your cluster. You also need to open ports 30001 up to the
>>> >> number of workers you will be running.
>>> >> So if you are running 10 workers then add the following to
>>> >> /etc/sysconfig/iptables
>>> >> -A INPUT -p tcp -m state --state NEW -m tcp --dport 30000:30010 -j
>>> ACCEPT
>>> >> Then restart iptables with:
>>> >> sudo service iptables restart
>>> >> I'm new to Giraph too so anyone please correct me if I'm wrong.
>>> >> Regards,
>>> >> Simon
>>> >>
>>> >>
>>> >> On Mon, Oct 21, 2013 at 3:37 PM, Andro Bermúdez Serrano <
>>> >> andro.bermudez@gmail.com> wrote:
>>> >>
>>> >>> Hello.
>>> >>> I am using Giraph 1.0.0 with hadoop 1.2.1. With the
>>> >>> pseudo-distributed
>>> >>> installation of hadoop the execution was succefully. Now I am trying
>>> >>> to run the same example but in a cluster. So far, I can't continue
>>> >>> because error in tasks. The exception: java.net.ConnectException.
My
>>> >>> experience in hadoop is almost null.
>>> >>>
>>> >>> Thanks.
>>> >>>
>>> >>> 2013-10-21 10:11:58,152 INFO
>>> >>> org.apache.hadoop.util.NativeCodeLoader:
>>> >>> Loaded the native-hadoop library
>>> >>> 2013-10-21 10:11:58,743 WARN
>>> >>> org.apache.hadoop.metrics2.impl.MetricsSystemImpl: Source name ugi
>>> >>> already exists!
>>> >>> 2013-10-21 10:11:59,431 INFO org.apache.hadoop.util.ProcessTree:
>>> >>> setsid exited with exit code 0
>>> >>> 2013-10-21 10:11:59,491 INFO org.apache.hadoop.mapred.Task:  Using
>>> >>> ResourceCalculatorPlugin :
>>> >>> org.apache.hadoop.util.LinuxResourceCalculatorPlugin@34bb5def
>>> >>> 2013-10-21 10:11:59,632 INFO org.apache.hadoop.mapred.MapTask:
>>> >>> Processing split: 'org.apache.giraph.bsp.BspInputSplit, index=-1,
>>> >>> num=-1
>>> >>> 2013-10-21 10:11:59,778 INFO
>>> >>> org.apache.giraph.graph.GraphTaskManager:
>>> >>> setup: Log level remains at info
>>> >>> 2013-10-21 10:12:00,426 INFO
>>> >>> org.apache.giraph.graph.GraphTaskManager:
>>> >>> Distributed cache is empty. Assuming fatjar.
>>> >>> 2013-10-21 10:12:00,454 INFO
>>> >>> org.apache.giraph.graph.GraphTaskManager:
>>> >>> setup: classpath @
>>> >>>
>>> >>>
>>> /app/hadoop/tmp/mapred/local/taskTracker/hadoop-user/jobcache/job_201310210926_0004/jars/job.jar
>>> >>> for job Giraph: org.apache.giraph.examples.SimplePageRankVertex
>>> >>> 2013-10-21 10:12:03,054 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> createCandidateStamp: Made the directory
>>> >>> _bsp/_defaultZkManagerDir/job_201310210926_0004
>>> >>> 2013-10-21 10:12:03,564 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> createCandidateStamp: Creating my filestamp
>>> >>> _bsp/_defaultZkManagerDir/job_201310210926_0004/_task/hdnode01 0
>>> >>> 2013-10-21 10:12:06,635 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> getZooKeeperServerList: Got [hdnode02, hdnode01] 2 hosts from 2
>>> >>> candidates when 1 required (polling period is 3000) on attempt 0
>>> >>> 2013-10-21 10:12:06,635 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> createZooKeeperServerList: Creating the final ZooKeeper file
>>> >>> '_bsp/_defaultZkManagerDir/job_201310210926_0004/zkServerList_hdnode02
>>> >>> 1 '
>>> >>> 2013-10-21 10:12:10,754 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> getZooKeeperServerList: For task 0, got file 'zkServerList_hdnode02
>>> >>> 1
>>> >>> ' (polling period is 3000)
>>> >>> 2013-10-21 10:12:10,754 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> getZooKeeperServerList: Found [hdnode02, 1] 2 hosts in filename
>>> >>> 'zkServerList_hdnode02 1 '
>>> >>> 2013-10-21 10:12:10,757 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> onlineZooKeeperSErvers: Empty directory
>>> >>> _bsp/_defaultZkManagerDir/job_201310210926_0004/_zkServer, waiting
>>> >>> 3000 msecs.
>>> >>> 2013-10-21 10:12:13,760 INFO org.apache.giraph.zk.ZooKeeperManager:
>>> >>> onlineZooKeeperServers: Got [hdnode02] 1 hosts from 1 ready servers
>>> >>> when 1 required (polling period is 3000) on attempt 1
>>> >>> 2013-10-21 10:12:13,783 INFO
>>> >>> org.apache.giraph.graph.GraphTaskManager:
>>> >>> setup: Starting up BspServiceWorker...
>>> >>> 2013-10-21 10:12:13,811 INFO org.apache.giraph.bsp.BspService:
>>> >>> BspService: Connecting to ZooKeeper with job job_201310210926_0004,
>>> >>> 0
>>> >>> on hdnode02:22181
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:zookeeper.version=3.3.3-1073969, built on 02/23/2011
>>> >>> 22:27
>>> >>> GMT
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:host.name=hdnode01
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:java.version=1.7.0_25
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:java.vendor=Oracle Corporation
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:java.home=/usr/lib/jvm/java-7-openjdk-amd64/jre
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>>
>>> >>>
>>> environment:java.class.path=/app/hadoop/tmp/mapred/local/taskTracker/hadoop-user/jobcache/job_201310210926_0004/jars/classes:/app/hadoop/tmp/mapred/local/taskTracker/hadoop-user/jobcache/job_201310210926_0004/jars:/app/hadoop/tmp/mapred/local/taskTracker/hadoop-user/jobcache/job_201310210926_0004/attempt_201310210926_0004_m_000000_0/work:/usr/local/hadoop/libexec/../conf:/usr/lib/jvm/java-7-openjdk-amd64/lib/tools.jar:/usr/local/hadoop/libexec/..:/usr/local/hadoop/libexec/../hadoop-core-1.2.1.jar:/usr/local/hadoop/libexec/../lib/asm-3.2.jar:/usr/local/hadoop/libexec/../lib/aspectjrt-1.6.11.jar:/usr/local/hadoop/libexec/../lib/aspectjtools-1.6.11.jar:/usr/local/hadoop/libexec/../lib/commons-beanutils-1.7.0.jar:/usr/local/hadoop/libexec/../lib/commons-beanutils-core-1.8.0.jar:/usr/local/hadoop/libexec/../lib/commons-cli-1.2.jar:/usr/local/hadoop/libexec/../lib/commons-codec-1.4.jar:/usr/local/hadoop/libexec/../lib/commons-collections-3.2.1.jar:/usr/local/hadoop/libexec/../lib/commons-configuration-1.6.jar:/usr/local/hadoop/libexec/../lib/commons-daemon-1.0.1.jar:/usr/local/hadoop/libexec/../lib/commons-digester-1.8.jar:/usr/local/hadoop/libexec/../lib/commons-el-1.0.jar:/usr/local/hadoop/libexec/../lib/commons-httpclient-3.0.1.jar:/usr/local/hadoop/libexec/../lib/commons-io-2.1.jar:/usr/local/hadoop/libexec/../lib/commons-lang-2.4.jar:/usr/local/hadoop/libexec/../lib/commons-logging-1.1.1.jar:/usr/local/hadoop/libexec/../lib/commons-logging-api-1.0.4.jar:/usr/local/hadoop/libexec/../lib/commons-math-2.1.jar:/usr/local/hadoop/libexec/../lib/commons-net-3.1.jar:/usr/local/hadoop/libexec/../lib/core-3.1.1.jar:/usr/local/hadoop/libexec/../lib/hadoop-capacity-scheduler-1.2.1.jar:/usr/local/hadoop/libexec/../lib/hadoop-fairscheduler-1.2.1.jar:/usr/local/hadoop/libexec/../lib/hadoop-thriftfs-1.2.1.jar:/usr/local/hadoop/libexec/../lib/hsqldb-1.8.0.10.jar:/usr/local/hadoop/libexec/../lib/jackson-core-asl-1.8.8.jar:/usr/local/hadoop/libexec/../lib/jackson-mapper-asl-1.8.8.jar:/usr/local/hadoop/libexec/../lib/jasper-compiler-5.5.12.jar:/usr/local/hadoop/libexec/../lib/jasper-runtime-5.5.12.jar:/usr/local/hadoop/libexec/../lib/jdeb-0.8.jar:/usr/local/hadoop/libexec/../lib/jersey-core-1.8.jar:/usr/local/hadoop/libexec/../lib/jersey-json-1.8.jar:/usr/local/hadoop/libexec/../lib/jersey-server-1.8.jar:/usr/local/hadoop/libexec/../lib/jets3t-0.6.1.jar:/usr/local/hadoop/libexec/../lib/jetty-6.1.26.jar:/usr/local/hadoop/libexec/../lib/jetty-util-6.1.26.jar:/usr/local/hadoop/libexec/../lib/jsch-0.1.42.jar:/usr/local/hadoop/libexec/../lib/junit-4.5.jar:/usr/local/hadoop/libexec/../lib/kfs-0.2.2.jar:/usr/local/hadoop/libexec/../lib/log4j-1.2.15.jar:/usr/local/hadoop/libexec/../lib/mockito-all-1.8.5.jar:/usr/local/hadoop/libexec/../lib/oro-2.0.8.jar:/usr/local/hadoop/libexec/../lib/servlet-api-2.5-20081211.jar:/usr/local/hadoop/libexec/../lib/slf4j-api-1.4.3.jar:/usr/local/hadoop/libexec/../lib/slf4j-log4j12-1.4.3.jar:/usr/local/hadoop/libexec/../lib/xmlenc-0.52.jar:/usr/local/hadoop/libexec/../lib/jsp-2.1/jsp-2.1.jar:/usr/local/hadoop/libexec/../lib/jsp-2.1/jsp-api-2.1.jar
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>>
>>> >>>
>>> environment:java.library.path=/usr/local/hadoop/libexec/../lib/native/Linux-amd64-64:/app/hadoop/tmp/mapred/local/taskTracker/hadoop-user/jobcache/job_201310210926_0004/attempt_201310210926_0004_m_000000_0/work
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>>
>>> >>>
>>> environment:java.io.tmpdir=/app/hadoop/tmp/mapred/local/taskTracker/hadoop-user/jobcache/job_201310210926_0004/attempt_201310210926_0004_m_000000_0/work/tmp
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:java.compiler=<NA>
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:os.name=Linux
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:os.arch=amd64
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:os.version=3.8.0-32-generic
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:user.name=hadoop-user
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>> environment:user.home=/home/hadoop-user
>>> >>> 2013-10-21 10:12:13,820 INFO org.apache.zookeeper.ZooKeeper: Client
>>> >>>
>>> >>>
>>> environment:user.dir=/app/hadoop/tmp/mapred/local/taskTracker/hadoop-user/jobcache/job_201310210926_0004/attempt_201310210926_0004_m_000000_0/work
>>> >>> 2013-10-21 10:12:13,821 INFO org.apache.zookeeper.ZooKeeper:
>>> >>> Initiating client connection, connectString=hdnode02:22181
>>> >>> sessionTimeout=60000
>>> >>> watcher=org.apache.giraph.worker.BspServiceWorker@54bf0a6b
>>> >>> 2013-10-21 10:12:13,861 INFO org.apache.zookeeper.ClientCnxn:
>>> >>> Opening
>>> >>> socket connection to server hdnode02/172.24.10.72:22181
>>> >>> 2013-10-21 10:12:13,870 INFO org.apache.zookeeper.ClientCnxn: Socket
>>> >>> connection established to hdnode02/172.24.10.72:22181, initiating
>>> >>> session
>>> >>> 2013-10-21 10:12:13,999 INFO org.apache.zookeeper.ClientCnxn:
>>> >>> Session
>>> >>> establishment complete on server hdnode02/172.24.10.72:22181,
>>> >>> sessionid = 0x141db5bd0d70000, negotiated timeout = 600000
>>> >>> 2013-10-21 10:12:14,001 INFO org.apache.giraph.bsp.BspService:
>>> >>> process: Asynchronous connection complete.
>>> >>> 2013-10-21 10:12:14,009 INFO
>>> >>> org.apache.giraph.comm.netty.NettyWorkerServer:
>>> >>> createMessageStoreFactory: Using ByteArrayMessagesPerVertexStore
>>> >>> since
>>> >>> there is no combiner
>>> >>> 2013-10-21 10:12:14,216 INFO
>>> >>> org.apache.giraph.comm.netty.NettyServer:
>>> >>> NettyServer: Using execution handler with 8 threads after
>>> >>> requestFrameDecoder.
>>> >>> 2013-10-21 10:12:14,369 INFO
>>> >>> org.apache.giraph.comm.netty.NettyServer:
>>> >>> start: Started server communication server:
>>> >>> hdnode01/172.24.9.185:30000 with up to 16 threads on bind attempt
0
>>> >>> with sendBufferSize = 32768 receiveBufferSize = 524288 backlog =
1
>>> >>> 2013-10-21 10:12:14,376 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> NettyClient: Using execution handler with 8 threads after
>>> >>> requestEncoder.
>>> >>> 2013-10-21 10:12:14,388 INFO
>>> >>> org.apache.giraph.graph.GraphTaskManager:
>>> >>> setup: Registering health of this worker...
>>> >>> 2013-10-21 10:12:14,637 INFO org.apache.giraph.bsp.BspService:
>>> >>> process: applicationAttemptChanged signaled
>>> >>> 2013-10-21 10:12:14,788 WARN org.apache.giraph.bsp.BspService:
>>> >>> process: Unknown and unprocessed event
>>> >>>
>>> >>>
>>> (path=/_hadoopBsp/job_201310210926_0004/_applicationAttemptsDir/0/_superstepDir,
>>> >>> type=NodeChildrenChanged, state=SyncConnected)
>>> >>> 2013-10-21 10:12:14,811 INFO
>>> >>> org.apache.giraph.worker.BspServiceWorker: registerHealth: Created
>>> >>> my
>>> >>> health node for attempt=0, superstep=-1 with
>>> >>>
>>> >>>
>>> /_hadoopBsp/job_201310210926_0004/_applicationAttemptsDir/0/_superstepDir/-1/_workerHealthyDir/hdnode01_0
>>> >>> and workerInfo= Worker(hostname=hdnode01, MRtaskID=0, port=30000)
>>> >>> 2013-10-21 10:12:15,568 INFO
>>> >>> org.apache.giraph.comm.netty.NettyServer:
>>> >>> start: Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,637 INFO org.apache.giraph.bsp.BspService:
>>> >>> process: partitionAssignmentsReadyChanged (partitions are assigned)
>>> >>> 2013-10-21 10:12:15,654 INFO
>>> >>> org.apache.giraph.worker.BspServiceWorker: startSuperstep:
>>> >>> Master(hostname=hdnode02, MRtaskID=1, port=30001)
>>> >>> 2013-10-21 10:12:15,654 INFO
>>> >>> org.apache.giraph.worker.BspServiceWorker: startSuperstep: Ready
for
>>> >>> computation on superstep -1 since worker selection and vertex range
>>> >>> assignments are done in
>>> >>>
>>> >>>
>>> /_hadoopBsp/job_201310210926_0004/_applicationAttemptsDir/0/_superstepDir/-1/_addressesAndPartitions
>>> >>> 2013-10-21 10:12:15,656 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,671 WARN
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Future failed to connect with
>>> >>> hdnode02/172.24.10.72:30001 with 0 failures because of
>>> >>> java.net.ConnectException: Connection refused
>>> >>> 2013-10-21 10:12:15,671 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,672 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Successfully added 0 connections, (0 total
>>> >>> connected) 1 failed, 1 failures total.
>>> >>> 2013-10-21 10:12:15,677 WARN
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Future failed to connect with
>>> >>> hdnode02/172.24.10.72:30001 with 1 failures because of
>>> >>> java.net.ConnectException: Connection refused
>>> >>> 2013-10-21 10:12:15,677 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,677 WARN
>>> >>> org.apache.giraph.comm.netty.handler.ResponseClientHandler:
>>> >>> exceptionCaught: Channel failed with remote address null
>>> >>> java.net.ConnectException: Connection refused
>>> >>>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> >>>         at
>>> >>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:404)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:366)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:282)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>> >>>         at java.lang.Thread.run(Thread.java:724)
>>> >>> 2013-10-21 10:12:15,681 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Successfully added 0 connections, (0 total
>>> >>> connected) 1 failed, 2 failures total.
>>> >>> 2013-10-21 10:12:15,682 WARN
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Future failed to connect with
>>> >>> hdnode02/172.24.10.72:30001 with 2 failures because of
>>> >>> java.net.ConnectException: Connection refused
>>> >>> 2013-10-21 10:12:15,682 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,684 WARN
>>> >>> org.apache.giraph.comm.netty.handler.ResponseClientHandler:
>>> >>> exceptionCaught: Channel failed with remote address null
>>> >>> java.net.ConnectException: Connection refused
>>> >>>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> >>>         at
>>> >>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:404)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:366)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:282)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>> >>>         at java.lang.Thread.run(Thread.java:724)
>>> >>> 2013-10-21 10:12:15,686 WARN
>>> >>> org.apache.giraph.comm.netty.handler.ResponseClientHandler:
>>> >>> exceptionCaught: Channel failed with remote address null
>>> >>> java.net.ConnectException: Connection refused
>>> >>>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> >>>         at
>>> >>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:404)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:366)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:282)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>> >>>         at java.lang.Thread.run(Thread.java:724)
>>> >>> 2013-10-21 10:12:15,687 WARN
>>> >>> org.apache.giraph.comm.netty.handler.ResponseClientHandler:
>>> >>> exceptionCaught: Channel failed with remote address null
>>> >>> java.net.ConnectException: Connection refused
>>> >>>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> >>>         at
>>> >>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:404)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:366)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:282)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>> >>>         at java.lang.Thread.run(Thread.java:724)
>>> >>> 2013-10-21 10:12:15,686 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Successfully added 0 connections, (0 total
>>> >>> connected) 1 failed, 3 failures total.
>>> >>> 2013-10-21 10:12:15,688 WARN
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Future failed to connect with
>>> >>> hdnode02/172.24.10.72:30001 with 3 failures because of
>>> >>> java.net.ConnectException: Connection refused
>>> >>> 2013-10-21 10:12:15,688 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,688 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Successfully added 0 connections, (0 total
>>> >>> connected) 1 failed, 4 failures total.
>>> >>> 2013-10-21 10:12:15,689 WARN
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Future failed to connect with
>>> >>> hdnode02/172.24.10.72:30001 with 4 failures because of
>>> >>> java.net.ConnectException: Connection refused
>>> >>> 2013-10-21 10:12:15,689 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,690 WARN
>>> >>> org.apache.giraph.comm.netty.handler.ResponseClientHandler:
>>> >>> exceptionCaught: Channel failed with remote address null
>>> >>> java.net.ConnectException: Connection refused
>>> >>>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> >>>         at
>>> >>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:404)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:366)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:282)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>> >>>         at java.lang.Thread.run(Thread.java:724)
>>> >>> 2013-10-21 10:12:15,690 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Successfully added 0 connections, (0 total
>>> >>> connected) 1 failed, 5 failures total.
>>> >>> 2013-10-21 10:12:15,692 WARN
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Future failed to connect with
>>> >>> hdnode02/172.24.10.72:30001 with 5 failures because of
>>> >>> java.net.ConnectException: Connection refused
>>> >>> 2013-10-21 10:12:15,692 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,692 WARN
>>> >>> org.apache.giraph.comm.netty.handler.ResponseClientHandler:
>>> >>> exceptionCaught: Channel failed with remote address null
>>> >>> java.net.ConnectException: Connection refused
>>> >>>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> >>>         at
>>> >>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:404)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:366)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:282)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>> >>>         at java.lang.Thread.run(Thread.java:724)
>>> >>> 2013-10-21 10:12:15,693 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Successfully added 0 connections, (0 total
>>> >>> connected) 1 failed, 6 failures total.
>>> >>> 2013-10-21 10:12:15,693 WARN
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> connectAllAddresses: Future failed to connect with
>>> >>> hdnode02/172.24.10.72:30001 with 6 failures because of
>>> >>> java.net.ConnectException: Connection refused
>>> >>> 2013-10-21 10:12:15,693 INFO
>>> >>> org.apache.giraph.comm.netty.NettyClient:
>>> >>> Using Netty without authentication.
>>> >>> 2013-10-21 10:12:15,694 WARN
>>> >>> org.apache.giraph.comm.netty.handler.ResponseClientHandler:
>>> >>> exceptionCaught: Channel failed with remote address null
>>> >>> java.net.ConnectException: Connection refused
>>> >>>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> >>>         at
>>> >>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:404)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:366)
>>> >>>         at
>>> >>>
>>> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:282)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>>> >>>         at
>>> >>>
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>> >>>         at java.lang.Thread.run(Thread.java:724)
>>> >>>
>>> >>
>>> >>
>>> >
>>> >
>>> > --
>>> >    Claudio Martella
>>> >    claudio.martella@gmail.com
>>> >
>>>
>>
>

Mime
View raw message