giraph-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jyotirmoy Sundi <>
Subject zookeeper connection issue while running for second time
Date Fri, 27 Sep 2013 01:08:09 GMT
Hi ,

   I got the connected component working for 1B nodes, but when I run
the job again, it fails with the below error. Aprt form this in
zookeeper the data is not cleared in the data directory. For
successful jobs the data in zookeper from giraph is cleared.

The following errors seems to be coming because the node tries to
connect to the zookeeper with a session id which is cleared as seens

"Client session timed out, have not heard from server in 68845ms for
sessionid 0x3415cc6ce930059, closing socket connection and attempting
reconnect" , Any idea if increasing the session time out will be good

2013-09-27 00:57:11,748 WARN org.apache.giraph.bsp.BspService:
process: Got unknown null path event WatchedEvent state:Expired
type:None path:null
2013-09-27 00:57:11,748 INFO org.apache.zookeeper.ClientCnxn: Unable
to reconnect to ZooKeeper service, session 0x3415cc6ce930059 has
expired, closing socket connection
2013-09-27 00:57:11,748 WARN
org.apache.giraph.worker.InputSplitsHandler: process: Problem with
zookeeper, got event with path null, state Expired, event type None
2013-09-27 00:57:11,748 INFO org.apache.zookeeper.ClientCnxn:
EventThread shut down
2013-09-27 00:57:11,925 INFO
org.apache.giraph.worker.InputSplitsCallable: loadFromInputSplit:
Finished loading
/_hadoopBsp/job_201309260044_0116/_vertexInputSplitDir/89 (v=258127,
2013-09-27 00:57:11,926 ERROR
org.apache.giraph.utils.LogStacktraceCallable: Execution of callable
java.lang.IllegalStateException: markInputSplitPathFinished:
KeeperException on
	at org.apache.giraph.worker.InputSplitsHandler.markInputSplitPathFinished(
	at org.apache.giraph.worker.InputSplitsCallable.loadInputSplit(
	at java.util.concurrent.FutureTask$Sync.innerRun(
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(
	at java.util.concurrent.ThreadPoolExecutor$
Caused by: org.apache.zookeeper.KeeperException$SessionExpiredException:
KeeperErrorCode = Session expired for
	at org.apache.zookeeper.KeeperException.create(
	at org.apache.zookeeper.KeeperException.create(
	at org.apache.zookeeper.ZooKeeper.create(
	at org.apache.giraph.zk.ZooKeeperExt.createExt(
	at org.apache.giraph.worker.InputSplitsHandler.markInputSplitPathFinished(
	... 9 more

Best Regards,
Jyotirmoy Sundi
Data Engineer,

San Francisco, CA 94158

View raw message