sql Abfrage zu Spark-Cassandra-Cluster Sparsamkeitsserver gibt nicht

Question

Ich habe eine Spark-Cassandra-Cluster eingerichtet. Cqlsh funktioniert gut. Ich habe den Thrift-Server gestartet und benutze die Beeline-Befehlszeile, um eine Verbindung herzustellen. Ich kann

use schemaname 
show schemas 
show tables 

tun, aber ein einfaches

select * from tablename 

stecken bleibt.

Ich habe versucht, einen Java-Client durch die JDBC: Hive2-Schnittstelle, zeigt es das gleiche Verhalten. Gute Ergebnisse in Show-Tabellen, aber keine Rückkehr auf eine einfache Select-Anweisung .

Die Spark-Konsole zeigt alle Jobs ohne Beanstandung. Der Job bleibt auf der Compiled-Phase hängen.

Jeder weiß, wie man das tiefer diagnostiziert?

Answer 1

Mir geht es gut mit der Codierung. Dieses Problem ist gelöst. Es ist so, weil diese Einrichtung nicht durch Garn geht, und die erste Instanz des Sparsamkeits-Servers alle Kerne in dem Cluster hochhob. Ich habe den Sql gegen die zweite Thriftserver-Instanz gefeuert, die 0 Kerne zur Verfügung hat.

Answer 2

temporäre Tabelle in Sql für Cassandra Tabelle erstellen. wie folgender Weg

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()