sql запрос к искро-кассандровому кластеру бережливый сервер не возвращается

Question

У меня есть кластер искры-кассандра. cqlsh работает просто отлично. Я начал бережливость и использовал командную строку beeline для подключения к ней. Я могу сделать

use schemaname 
show schemas 
show tables 

но простой

select * from tablename 

застревает.

Я попробовал java-клиент, проходящий через интерфейс jdbc: hive2, он показывает то же поведение. Хорошие результаты в отображаемых таблицах, но нет возврата на простой оператор select.

Консоль искры показывает все задания без признаков жалобы. работа застряла на скомпилированном этапе.

Любой знает, как диагностировать это глубже?

Answer 1

Я в порядке с кодировкой. Эта проблема решена. Это связано с тем, что эта настройка не проходит через пряжу, и первый экземпляр triftserver забил все ядра в кластере. Я уволил sql против второго экземпляра thriftserver, который имеет в своем распоряжении 0 ядер.

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