启动图（DSEGraphFrame）时出错 [英] Error when launching the graph (DSEGraphFrame )

问题描述

我在验证/产品环境中有一个dse图。
当我尝试在Scala中使用Spark启动DSEGraphFrame查询时，会出现问题。

I have a dse graph in validation/prod environement. The problem occurs when I try to launch a DSEGraphFrame query using Spark in Scala.

val graph = spark.dseGraph("my_graph")

生成以下异常：

线程主中的异常
com.datastax.driver.core.exceptions.InvalidQueryException：方法
DseGraphRpc.getSchemaBlob不存在。确保该方法所需的
组件在com.datastax.driver.core.exceptions.InvalidQueryException.copy（InvalidQueryException.java:40）处处于活动状态/已启用com.datastax.driver.core.com .driver.core.DriverThrowables.propagateCause（DriverThrowables.java:26）
在com.datastax.driver.core.DefaultResultSetFuture.getUninterruptible（DefaultResultSetFuture.java:284）
在com.datastax.driver.core .AbstractSession.execute（AbstractSession.java:49）
在sun.reflect.NativeMethodAccessorImpl.invoke0（本机方法）
在sun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:62）
在sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43）在Java.lang.reflect.Method.invoke（Method.java:498）
在com.datastax.spark.connector.cql .SessionProxy.invoke（SessionProxy.scala：37）
在com.sun.proxy。$ Proxy27.execute（未知来源）
在sun.reflect.NativeMe thodAccessorImpl.invoke0（本机方法）
在sun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:62）
在sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43）
在java.lang.reflect.Method.invoke（Method.java:498）在com.datastax.spark.connector.cql.SessionProxy.invoke（SessionProxy.scala：37）
在com.sun。 proxy。$ Proxy28.execute（来源不明）
（位于com.datastax.bdp.util.rpc.RpcUtil.callInternal（RpcUtil.java:57）
位于com.datastax.bdp.util.rpc。 RpcUtil.call（RpcUtil.java:40）
在com.datastax.bdp.graph.spark.DseGraphRpc.callGetSchema（DseGraphRpc.java:45）
在com.datastax.bdp.graph.spark。 graphframe.DseGraphFrame $$ anonfun $ getSchemaFromServer $ 1.apply（DseGraphFrame.scala：586）
在com.datastax.bdp.graph.spark.graphframe.DseGraphFrame $$ anonfun $ getSchemaFromServer $ 1.apply（DseGraphFrame.scala：586 ）com.datastax.spark.connector.cql.Cassandra中的
Connector $$ anonfun $ withSessionDo $ 1.apply（CassandraConnector.scala：115）
在com.datastax.spark.connector.cql.CassandraConnector $$ anonfun $ withSessionDo $ 1.apply（CassandraConnector.scala：114）
在com.datastax.spark.connector.cql.CassandraConnector.closeResourceAfterUse（CassandraConnector.scala：158）
在com.datastax.spark.connector.cql.CassandraConnector.withSessionDo（CassandraConnector.scala：114）
在com.datastax.bdp.graph.spark.graphframe.DseGraphFrame $ .getSchemaFromServer（DseGraphFrame.scala：586）
在com.datastax.bdp.graph.spark.graphframe.DseGraphFrameBuilder $ .apply（DseGraphFrameBuilder.scala ：257）com.datastax.bdp.graph.spark.graphframe.SparkSessionFunctions.dseGraph（SparkSessionFunctions.scala：20）上的

Exception in thread "main" com.datastax.driver.core.exceptions.InvalidQueryException: The method DseGraphRpc.getSchemaBlob does not exist. Make sure that the required component for that method is active/enabled at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:40) at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:26) at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:284) at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:49) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at com.datastax.spark.connector.cql.SessionProxy.invoke(SessionProxy.scala:37) at com.sun.proxy.$Proxy27.execute(Unknown Source) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at com.datastax.spark.connector.cql.SessionProxy.invoke(SessionProxy.scala:37) at com.sun.proxy.$Proxy28.execute(Unknown Source) at com.datastax.bdp.util.rpc.RpcUtil.callInternal(RpcUtil.java:57) at com.datastax.bdp.util.rpc.RpcUtil.call(RpcUtil.java:40) at com.datastax.bdp.graph.spark.DseGraphRpc.callGetSchema(DseGraphRpc.java:45) at com.datastax.bdp.graph.spark.graphframe.DseGraphFrame$$anonfun$getSchemaFromServer$1.apply(DseGraphFrame.scala:586) at com.datastax.bdp.graph.spark.graphframe.DseGraphFrame$$anonfun$getSchemaFromServer$1.apply(DseGraphFrame.scala:586) at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$withSessionDo$1.apply(CassandraConnector.scala:115) at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$withSessionDo$1.apply(CassandraConnector.scala:114) at com.datastax.spark.connector.cql.CassandraConnector.closeResourceAfterUse(CassandraConnector.scala:158) at com.datastax.spark.connector.cql.CassandraConnector.withSessionDo(CassandraConnector.scala:114) at com.datastax.bdp.graph.spark.graphframe.DseGraphFrame$.getSchemaFromServer(DseGraphFrame.scala:586) at com.datastax.bdp.graph.spark.graphframe.DseGraphFrameBuilder$.apply(DseGraphFrameBuilder.scala:257) at com.datastax.bdp.graph.spark.graphframe.SparkSessionFunctions.dseGraph(SparkSessionFunctions.scala:20)

我该怎么办才能正确运行DSEGraphFrame？

What could I do to run DSEGraphFrame properly?

推荐答案

问题来自dse集群中的一个节点，而该图形不在没有激活

The problem comes from a node in dse cluster wich the graph isn't activated

这篇关于启动图（DSEGraphFrame）时出错的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！