Hi Giraphers, Just a small question. In ComputeCallable.computePartition, partition access is locked with synchronized(partition) to "make sure this is thread-safe across runs". I may not get the whole picture clearly, but this lock looks redundant to me. If every thread polled its partitionIds from a BlockingQueue, how could two threads work on the same partition?
Thanks,
