sql查询不返回

vs91vp4v 于 2021-06-29 发布在 Hive

关注(0)|答案(2)|浏览(462)

我有一个SparkCassandra集群设置。cqlsh工作正常。我启动了thriftserver并使用beeline命令行连接到它。我能做到

use schemaname
show schemas
show tables

但是一个简单的

select * from tablename

被卡住了。
我尝试了一个java客户端jdbc:hive2 interface，它表现出相同的行为。在show表上有很好的结果，但在简单的select语句上没有返回。
Spark控制台显示所有的工作没有任何抱怨的迹象。这项工作还停留在编译阶段。
有人知道如何更深入地诊断吗？

Hive jdbc beeline spark-cassandra-connector thrift

来源：https://stackoverflow.com/questions/36993345/sql-query-to-spark-cassandra-cluster-thriftserver-does-not-return

2条答案

按热度按时间

qvk1mo1f1#

我对编码很在行。这个问题解决了。这是因为此设置不会通过线程，而且thriftserver的第一个示例占用了集群中的所有核心。我对第二个thriftserver示例启动了sql，该示例有0个内核可供使用。

赞(0）回复(0）举报 2021-06-29

gwbalxhn2#

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

赞(0）回复(0）举报 2021-06-29

我来回答

sql查询不返回

2条答案

相关问题

热门标签

最新问答