You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@giraph.apache.org by "Sergey Edunov (JIRA)" <ji...@apache.org> on 2016/07/27 18:12:20 UTC

[jira] [Created] (GIRAPH-1100) Multiple mutation requests to one vertex result in failure

Sergey Edunov created GIRAPH-1100:
-------------------------------------

             Summary: Multiple mutation requests to one vertex result in failure
                 Key: GIRAPH-1100
                 URL: https://issues.apache.org/jira/browse/GIRAPH-1100
             Project: Giraph
          Issue Type: Bug
            Reporter: Sergey Edunov
            Assignee: Sergey Edunov


The scenario is simple:
You send multiple addEdgeRequest() where the source vertex of new edge does not exist (typical scenario for adding reverse edges). If two of these requests happen to arrive in the single SendPartitionMutationsRequest, giraph is unable to handle it:


FATAL   2016-07-26 17:59:09,563 [netty-server-worker-6] org.apache.giraph.graph.GraphTaskManager  - uncaughtException: OverrideExceptionHandler on thread netty-server-worker-6, msg = readFields: Already has vertex id 977939745592684, exiting...
java.lang.IllegalStateException: readFields: Already has vertex id 977939745592684
	at org.apache.giraph.comm.requests.SendPartitionMutationsRequest.readFieldsRequest(SendPartitionMutationsRequest.java:98)
	at org.apache.giraph.comm.requests.WritableRequest.readFields(WritableRequest.java:118)
	at org.apache.giraph.utils.RequestUtils.decodeWritableRequest(RequestUtils.java:52)
	at org.apache.giraph.comm.netty.handler.RequestDecoder.channelRead(RequestDecoder.java:89)
	at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338)
	at io.netty.channel.DefaultChannelHandlerContext.access$700(DefaultChannelHandlerContext.java:29)
	at io.netty.channel.DefaultChannelHandlerContext$8.run(DefaultChannelHandlerContext.java:329)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:354)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:353)
	at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)