Just an ack if anybody faces the same issue.This issue has to do with a previous version of guava11.0.2 used in cdh4, its fixed now.
Thanks Sundi On Thu, Oct 10, 2013 at 11:57 AM, Jyotirmoy Sundi <[email protected]>wrote: > 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 <[email protected]>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 > -- Best Regards, Jyotirmoy Sundi Data Engineer, Admobius San Francisco, CA 94158
