spark-cassandraクラスタthriftserverへのsqlクエリは返されません

Question

spark-cassandraクラスタが設定されています。 cqlshはうまく動作します。私はthriftserverを起動し、それに接続するためのコマンドラインを使用しました。私は

use schemaname 
show schemas 
show tables 

を行うことができますが、簡単な

select * from tablename 

がはまり込みます。

jdbc：hive2インターフェイスを使用してJavaクライアントを試しましたが、これは同じ動作を示しています。ショーテーブルでは良好な結果が得られましたが、単純なselectステートメントでは返されませんでした（ ）。

スパークコンソールは、苦情の兆候のないすべてのジョブを表示します。コンパイルされた段階でジョブが停止しています。

これをより深く診断する方法を知っている人はいますか？

Answer 1

私はコーディングでうまくいきます。この問題は解決されました。これは、このセットアップが糸を通らず、最初のインスタンスのthriftserverがクラスター内のすべてのコアを突っ込んだためです。私は処分時に0コアを持つ2番目のthriftserverインスタンスに対してsqlを起動しました。

Answer 2

sqlでcassandraテーブルのテンポラリテーブルを作成します。次のような方法

scala> sqlContext.sql(
    """CREATE TEMPORARY TABLE words 
    |USING org.apache.spark.sql.cassandra 
    |OPTIONS (
    | table "words", 
    | keyspace "test", 
    | cluster "Test Cluster", 
    | pushdown "true" 
    |)""".stripMargin) 
scala> val df = sqlContext.sql("SELECT * FROM words") 
scala> df.show()