giraph-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jyotirmoy Sundi <sundi...@gmail.com>
Subject Re: Error: java.lang.IllegalStateException: addPartition: cannot add partition
Date Thu, 10 Oct 2013 18:57:54 GMT
Hi,
      It seems like a bug with synchronization while trying to add
partitions, any help ?


*Error Trace:*

java.lang.IllegalStateException: addPartition: cannot add partition 8638
	at org.apache.giraph.partition.DiskBackedPartitionStore.addPartition(DiskBackedPartitionStore.java:278)
	at org.apache.giraph.comm.requests.SendVertexRequest.doRequest(SendVertexRequest.java:81)
	at org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor.doRequest(NettyWorkerClientRequestProcessor.java:470)
	at org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor.sendPartitionRequest(NettyWorkerClientRequestProcessor.java:203)
	at org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor.flush(NettyWorkerClientRequestProcessor.java:403)
	at org.apache.giraph.worker.InputSplitsCallable.call(InputSplitsCallable.java:192)
	at org.apache.giraph.worker.InputSplitsCallable.call(InputSplitsCallable.java:58)
	at org.apache.giraph.utils.LogStacktraceCallable.call(LogStacktraceCallable.java:51)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Caused by: java.util.concurrent.ExecutionException:
java.lang.IllegalMonitorStateException
	at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
	at java.util.concurrent.FutureTask.get(FutureTask.java:83)
	at org.apache.giraph.partition.DiskBackedPartitionStore.addPartition(DiskBackedPartitionStore.java:273)
	... 12 more
Caused by: java.lang.IllegalMonitorStateException
	at java.util.concurrent.locks.ReentrantReadWriteLock$Sync.tryRelease(ReentrantReadWriteLock.java:317)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1239)
	at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock(ReentrantReadWriteLock.java:992)
	at org.apache.giraph.partition.DiskBackedPartitionStore$AddPartition.call(DiskBackedPartitionStore.java:811)
	at org.apache.giraph.partition.DiskBackedPartitionStore$AddPartition.call(DiskBackedPartitionStore.java:729)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at org.apache.giraph.partition.DiskBackedPartitionStore$DirectExecutorService.execute(DiskBackedPartitionStore.java:895)
	at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)



On Wed, Oct 9, 2013 at 9:13 PM, Jyotirmoy Sundi <sundi133@gmail.com> wrote:

> Hi,
>
> Any pointers on this error would be appreciated.
>
> java.lang.IllegalStateException: addPartition: cannot add partition 20934
> 	at org.apache.giraph.partition.DiskBackedPartitionStore.addPartition(DiskBackedPartitionStore.java:278)
> 	at org.apache.giraph.comm.requests.SendVertexRequest.doRequest(SendVertexRequest.java:81)
> 	at org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor.doRequest(NettyWorkerClientRequestProcessor.java:470)
> 	at org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor.sendPartitionRequest(NettyWorkerClientRequestProcessor.java:203)
> 	at org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor.flush(NettyWorkerClientRequestProcessor.java:403)
> 	at org.apache.giraph.worker.InputSplitsCallable.call(InputSplitsCallable.java:192)
> 	at org.apache.giraph.worker.InputSplitsCallable.call(InputSplitsCallable.java:58)
> 	at org.apache.giraph.utils.LogStacktraceCallable.call(LogStacktraceCallable.java:51)
> 	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> 	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
> 	at java.lang.Thread.run(Thread.java:662)
> Caused by: java.util.concurrent.ExecutionException: java.lang.IllegalMonitorStateException
> 	at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
> 	at java.util.concurrent.FutureTask.get(FutureTask.java:83)
> 	at org.apache.giraph.partition.DiskBackedPartitionStore.addPartition(DiskBackedPartitionStore.java:273)
> 	... 12 more
>
>
> --
> Best Regards,
> Jyotirmoy Sundi
> Data Engineer,
> Admobius
>
> San Francisco, CA 94158
>



-- 
Best Regards,
Jyotirmoy Sundi
Data Engineer,
Admobius

San Francisco, CA 94158

Mime
View raw message