IOException is thrown when RestAPI.executeBatch() is called.

frandro

unread,

Feb 10, 2014, 6:33:57 AM2/10/14

to ne...@googlegroups.com

I'm trying to insert a number of nodes using Java REST binding.

This example is from the BatchRestAPITest class in java-rest-binding-neo4j-rest-graphdb-2.0.0-M06.

In the for loop, i is from 1 to 394. Within this scope, there's no problem.

When it's increased to 395 and more, an Exception is thrown and the nodes are not created.

The exception is as follows.

It seems like that when returned results from the REST API are more than a threshold, an IOException is thrown.

I didn't do any settings for this, neo4j is just run as a server.

Exception in thread "main" com.sun.jersey.api.client.ClientHandlerException: java.io.IOException: Premature EOF
 at com.sun.jersey.api.client.ClientResponse.getEntity(ClientResponse.java:575)
 at com.sun.jersey.api.client.ClientResponse.getEntity(ClientResponse.java:517)
 at org.neo4j.rest.graphdb.RequestResult.extractFrom(RequestResult.java:87)
 at org.neo4j.rest.graphdb.ExecutingRestRequest.post(ExecutingRestRequest.java:151)
 at org.neo4j.rest.graphdb.ExecutingRestAPI.batch(ExecutingRestAPI.java:591)
 at org.neo4j.rest.graphdb.batch.BatchRestAPI.executeBatchRequest(BatchRestAPI.java:135)
 at org.neo4j.rest.graphdb.BatchTransaction.close(BatchTransaction.java:79)
 at org.neo4j.rest.graphdb.RestAPIFacade.executeBatch(RestAPIFacade.java:312)
 at NodeManager.createNodes(NodeManager.java:131)
 at StressTest.createUserNodes(StressTest.java:89)
 at StressTest.createNodesRelations(StressTest.java:40)
 at MainClass.testStressTest(MainClass.java:34)
 at MainClass.main(MainClass.java:47)
Caused by: java.io.IOException: Premature EOF
 at sun.net.www.http.ChunkedInputStream.readAheadBlocking(Unknown Source)
 at sun.net.www.http.ChunkedInputStream.readAhead(Unknown Source)
 at sun.net.www.http.ChunkedInputStream.read(Unknown Source)
 at java.io.FilterInputStream.read(Unknown Source)
 at sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(Unknown Source)
 at sun.nio.cs.StreamDecoder.readBytes(Unknown Source)
 at sun.nio.cs.StreamDecoder.implRead(Unknown Source)
 at sun.nio.cs.StreamDecoder.read(Unknown Source)
 at java.io.InputStreamReader.read(Unknown Source)
 at java.io.Reader.read(Unknown Source)
 at com.sun.jersey.core.util.ReaderWriter.readFromAsString(ReaderWriter.java:171)
 at com.sun.jersey.core.util.ReaderWriter.readFromAsString(ReaderWriter.java:157)
 at com.sun.jersey.core.provider.AbstractMessageReaderWriterProvider.readFromAsString(AbstractMessageReaderWriterProvider.java:114)
 at com.sun.jersey.core.impl.provider.entity.StringProvider.readFrom(StringProvider.java:73)
 at com.sun.jersey.core.impl.provider.entity.StringProvider.readFrom(StringProvider.java:58)
 at com.sun.jersey.api.client.ClientResponse.getEntity(ClientResponse.java:565)
 ... 12 more

This is the test code. graphDB is an instance of RestGraphDatabase.

 RestAPI restAPI = graphDB.getRestAPI(); 
 
        TestBatchResult response = restAPI.executeBatch(new BatchCallback<TestBatchResult>() {
            @Override
            public TestBatchResult recordBatch(RestAPI batchRestApi) {
                TestBatchResult result=new TestBatchResult();
                result.n1=batchRestApi.createNode(map("name", "node0"));
                for (int i=1;i<=394;i++) {
                    result.n2=batchRestApi.createNode(map("name", "node"+i));
                }
                return result;
            }
        });
        Transaction transaction = graphDB.beginTx();
        try {
        System.out.println("node0 equals: " + "node0".equals(response.n1.getProperty("name")));
        System.out.println("node1000 equals: " + "node1000".equals(response.n2.getProperty("name")));
        } finally {
            transaction.success();
            transaction.close();
        }

Michael Hunger

unread,

Feb 10, 2014, 6:37:05 AM2/10/14

to ne...@googlegroups.com

Probably a connection timeout (I think the default is 30s).

Or a problem on the server (please check data/logs/console.log and data/graph.db/messages.log)

Michael

--
You received this message because you are subscribed to the Google Groups "Neo4j" group.
To unsubscribe from this group and stop receiving emails from it, send an email to neo4j+un...@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

frandro

unread,

Feb 10, 2014, 7:00:49 AM2/10/14

to ne...@googlegroups.com

in the messages.log

2014-02-10 11:56:17.592+0000 WARN [o.n.s.r.w.BatchOperationService]: Error executing batch request

java.nio.BufferOverflowException: null

at java.nio.Buffer.nextPutIndex(Buffer.java:513) ~[na:1.7.0_45]

at java.nio.HeapByteBuffer.put(HeapByteBuffer.java:163) ~[na:1.7.0_45]

at org.eclipse.jetty.util.BufferUtil.append(BufferUtil.java:376) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:230) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.spi.container.servlet.WebComponent$Writer.write(WebComponent.java:292) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.spi.container.ContainerResponse$CommittingOutputStream.write(ContainerResponse.java:139) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.web.BatchOperationService$1$1.write(BatchOperationService.java:95) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at java.io.OutputStream.write(OutputStream.java:116) ~[na:1.7.0_45]

at org.codehaus.jackson.impl.Utf8Generator._flushBuffer(Utf8Generator.java:1754) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.codehaus.jackson.impl.Utf8Generator.close(Utf8Generator.java:1119) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.batch.StreamingBatchOperationResults.writeError(StreamingBatchOperationResults.java:155) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.web.StreamingBatchOperations.invoke(StreamingBatchOperations.java:84) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.batch.BatchOperations.performRequest(BatchOperations.java:201) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.batch.BatchOperations.parseAndPerform(BatchOperations.java:171) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.web.StreamingBatchOperations.readAndExecuteOperations(StreamingBatchOperations.java:57) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.web.BatchOperationService$1.write(BatchOperationService.java:98) ~[neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.spi.container.ContainerResponse.write(ContainerResponse.java:306) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.server.impl.application.WebApplicationImpl._handleRequest(WebApplicationImpl.java:1437) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.server.impl.application.WebApplicationImpl.handleRequest(WebApplicationImpl.java:1349) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.server.impl.application.WebApplicationImpl.handleRequest(WebApplicationImpl.java:1339) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.spi.container.servlet.WebComponent.service(WebComponent.java:416) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.spi.container.servlet.ServletContainer.service(ServletContainer.java:537) [neo4j-desktop-2.0.0.jar:2.0.0]

at com.sun.jersey.spi.container.servlet.ServletContainer.service(ServletContainer.java:699) [neo4j-desktop-2.0.0.jar:2.0.0]

at javax.servlet.http.HttpServlet.service(HttpServlet.java:848) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:698) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1506) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.neo4j.server.rest.security.SecurityFilter.doFilter(SecurityFilter.java:112) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1477) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:503) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:211) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1096) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:432) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:175) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1030) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:136) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.handler.HandlerList.handle(HandlerList.java:52) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.Server.handle(Server.java:445) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:268) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:229) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.io.AbstractConnection$ReadCallback.run(AbstractConnection.java:358) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:601) [neo4j-desktop-2.0.0.jar:2.0.0]

at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:532) [neo4j-desktop-2.0.0.jar:2.0.0]

at java.lang.Thread.run(Thread.java:744) [na:1.7.0_45]

And the command output means idle timeout expired

20:56:17.533 [qtp2651046-52] WARN o.e.jetty.servlet.ServletHandler - /db/data/node

javax.ws.rs.WebApplicationException: javax.ws.rs.WebApplicationException: java.io.IOException: java.util.concurrent.TimeoutException: Idle timeout expired: 30001/30000 ms

at org.neo4j.server.rest.repr.OutputFormat$1.write(OutputFormat.java:174) ~[neo4j-desktop-2.0.0.jar:2.0.0]