Ошибка dse spark после включения унифицированной аутентификации DSE

Я обновил DSE до версии 5.1.2 и включил унифицированную аутентификацию DSE.

Когда я запускаю «dse -u xxx -p xxx spark», я получаю оболочку, но если я отправлю запрос, используя «spark.sql», я получаю сообщение об ошибке:

scala> val result = spark.sql("SELECT id FROM xxx.yyy")
java.lang.RuntimeException: com.datastax.bdp.fs.client.InternalServerException: Server returned HTTP error response  500 (Internal Server Error)
Caused by: com.datastax.bdp.fs.client.InternalServerException: Server returned HTTP error response  500 (Internal Server Error)
  at com.datastax.bdp.fs.client.DseFsClient$stateMachine$macro$1$1.apply(DseFsClient.scala:132)

В /var/log/cassandra/system.log я вижу:

WARN  [Native-Transport-Requests-2] 2017-08-31 12:05:29,057  DseAuthenticator.java:659 - Plain text authentication without client / server encryption is strongly discouraged
ERROR [dsefs-netty-worker-4] 2017-08-31 12:05:29,842 DSEFS RestServerHandler.scala:287 - [id: 0x1810ea2d, L:/10.225.155.31:5598 - R:/10.225.155.31:58006] RestHandler invocation failed
java.util.concurrent.ExecutionException: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (no host was tried)
    at com.google.common.util.concurrent.AbstractFuture$Sync.getValue(AbstractFuture.java:299) ~[guava-18.0.jar:na]
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (no host was tried)

Любая идея, как это исправить. Кстати, dse spark-submit работает...


person Kilian    schedule 31.08.2017    source источник


Ответы (1)


Проблема решилась включением dsefs в dse.yaml.

person Kilian    schedule 07.09.2017