У меня есть граф dse в среде валидации / тестирования.Проблема возникает, когда я пытаюсь запустить запрос DSEGraphFrame с помощью Spark в Scala.
val graph = spark.dseGraph("my_graph")
создает следующее исключение:
Исключение в потоке "main" com.datastax.driver.core.exceptions.InvalidQueryException: метод DseGraphRpc.getSchemaBlob не существует.Убедитесь, что обязательный компонент для этого метода активен / включен в com.datastax.driver.core.exceptions.InvalidQueryException.copy (InvalidQueryException.java:40) в com.datastax.driver.core.DriverThrowables.propagateCause (DriverThrowables.java): 26) в com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly (DefaultResultSetFuture.java:284) в com.datastax.driver.core.AbstractSession.execute (AbstractSession.java:49) в sun.reflect.NorIСобственный метод) в sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) в sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) в java.vo.etg.reg ()на com.datastax.spark.connector.cql.SessionProxy.invoke (SessionProxy.scala: 37) на com.sun.proxy. $ Proxy27.execute (неизвестный источник) на sun.reflect.NativeMethodAccessorImpl.invoke0 (собственный метод) на солнце.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) на солнце.отражать.на 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 $$ anappfly $ getSvermaFrom $(DseGraphFrame.scala: 586) по адресу com.datastax.bdp.graph.spark.graphframe.DseGraphFrame $$ anonfun $ getSchemaFromServer $ 1.apply (DseGraphFrame.scala: 586) по адресу com.datastax.spark.connector.raq.ccanonfun $ withSessionDo $ 1.apply (CassandraConnector.scala: 115) в com.datastax.spark.connector.cql.CassandraConnector $$ anonfun $ сSessionDo $ 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 $ .getServerFrame $ .getS: 586) в com.datastax.bdp.graph.spark.graphframe.DseGraphFrameBuilder $ .apply (DseGraphFrameBuilder.scala: 257) в com.datastax.bdp.graph.spark.graphframe.SparkSessionFunctions.dseGraph: Spsc.
Что я могу сделать, чтобы правильно запустить DSEGraphFrame?