2016-04-19 14 views
1

gremlin-driverを使用してWebSockets経由でサーバータイタンインスタンスを照会しようとしています。 ので、私は次の依存関係があります。次のコマンドを使用して値を取得しようGremlinドライバがtitandbからrepsponseを取得できません

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

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

そして、次の例外を取得する:

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 

はオーバー実用例が見つかりませんでしたgremlin-driverを使ったCRUDアクションに関するWeb 誰もそれに対処する方法を知っていますか?

編集1: titan-1.0.0-hadoop1を使用 ドライババージョン3.0.1でインキュベートしても、同じIndexOutOfBoundsExceptionが試されます。

+0

を助けることができますか? –

+1

Titanバージョン1.0を使用している場合は、おそらくgremlinドライバをバージョン3.0.1-incubatingで使用する必要があります –

答えて

1

はこれを試してください:それはあなたが使用しているタイタンのバージョンは何

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()); 
関連する問題