JanusGraph с SparkComputer выдает исключение: GetNewApplicationRequestProto не может быть приведен к com.google.protobuf.Message

Question

Когда я использую JanusGraph2.0 и зажигаю пряжу на компьютере, например:

gremlin> graph = GraphFactory.open('conf/hadoop-graph/hadoop-load.properties')
==>hadoopgraph[gryoinputformat->nulloutputformat]
gremlin> blvp = BulkLoaderVertexProgram.build().writeGraph('conf/janusgraph-cassandra.properties').create(graph)
==>BulkLoaderVertexProgram[bulkLoader=IncrementalBulkLoader,vertexIdProperty=bulkLoader.vertex.id,userSuppliedIds=false,keepOriginalIds=true,batchSize=0]
gremlin> graph.compute(SparkGraphComputer).program(blvp).submit().get()

это вызывает исключение:

08:57:03 ERROR org.apache.spark.SparkContext  - Error initializing SparkContext.
java.lang.ClassCastException: org.apache.hadoop.yarn.proto.YarnServiceProtos$GetNewApplicationRequestProto cannot be cast to com.google.protobuf.Message
 at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:226)
 at com.sun.proxy.$Proxy23.getNewApplication(Unknown Source)

Может кто-нибудь помочь мне решить эту проблему? Спасибо

Answer 1

Этот вопрос был добавлен в janusgraph-пользователи и там ответили.

Проверьте матрицу совместимости версий. JanusGraph 0.2.0 не совместим с Spark 2.11. http://docs.janusgraph.org/latest/version-compat.html

JanusGraph 0.2.0 скомпилирован / протестирован с Spark 1.6.1. Убедитесь, что выровняли версии.