我在验证/产品环境中有一个 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?