2017-08-31 7 views
0

DSEを5.1.2に更新し、DSEユニファイド認証を有効にしました。DSEユニファイド認証を有効にした後に "dse spark"が失敗する

私は "DSE -u XXX -p XXXスパーク" を実行すると、私はシェルを得るが、私は "spark.sql" を使用してクエリを送信する場合、私はエラーを取得する:では/ var

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) 

/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 works ...

答えて

0

dse.yamlでdsefsを有効にすることで問題は解決しました。

関連する問題