2016-04-19 5 views
1

Ich versuche, eine Server-Titan-Instanz über WebSockets mit Gremlin-Treiber abzufragen. so habe ich nächste Abhängigkeit:Gremlin-Treiber kann keine Antwort von titandb erhalten

<dependency> 
     <groupId>org.apache.tinkerpop</groupId> 
     <artifactId>gremlin-driver</artifactId> 
     <version>3.1.1-incubating</version> 
    </dependency> 

Der Versuch, einen Wert mit nächsten Befehl zu erhalten:

 List<Result> some = client.submit("g.V().has(T.label, marketplace).has('marketplace_product_id', marketplace_product_id)", params).some(1).get(); 

Und immer nächste Ausnahme:

WARN o.a.t.g.driver.MessageSerializer - Response [PooledUnsafeDirectByteBuf(ridx: 136, widx: 136, cap: 136)] could not be deserialized by org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0. 
13:41:36.879 [gremlin-driver-loop-1] ERROR o.a.t.g.d.Handler$GremlinResponseHandler - Could not process the response 
io.netty.handler.codec.DecoderException: org.apache.tinkerpop.gremlin.driver.ser.SerializationException: java.lang.IndexOutOfBoundsException: Index: 121, Size: 0 

nicht ein funktionierendes Beispiel über gefunden Hat das Web über CRUD-Aktionen mit Gremlin-Treiber. Kann jemand damit umgehen?

Edit 1: Verwendung titan-1.0.0-hadoop1 Versucht auch mit Treiberversion 3.0.1-Inkubation und bekam fast die gleiche IndexOutOfBoundsException.

+0

Welche Version von Titan helfen wird, verwenden Sie? –

+1

Wenn Sie Titan Version 1.0 verwenden, müssen Sie wahrscheinlich den Gremlin Treiber mit der Version 3.0.1-inkubieren verwenden –

Antwort

1

versuchen Sie dies: sein Kann es

List<Result> some = null; 
some = client.submit("g.V() 
       .has(T.label,marketplace) 
       .has('marketplace_product_id', marketplace_product_id)") 
      .stream()** 
      .map(r -> r.get(Vertex.class))** 
      .collect(Collectors.toList()); 
Verwandte Themen