scala - 启动图形时出错 (DSEGraphFrame )

Question

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

val graph = spark.dseGraph("my_graph")

生成以下异常：

线程“主”com.datastax.driver.core.exceptions.InvalidQueryException 中的异常：方法 DseGraphRpc.getSchemaBlob 不存在。确保该方法所需的组件在 com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java 的 com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:40) 处处于活动状态/启用状态:26) 在 com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(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.

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

标签： scalaapache-sparkgremlindatastax-enterprise-graphdse-graph-frames

Answer 1

问题来自 dse 集群中的一个节点，该图未激活