我是spark和spark sql的新手,我试图在Spark SQL网站上创建示例,在从JSON文件目录加载模式和数据后只是一个简单的SQL查询,如下所示:
import sqlContext.createSchemaRDD
val sqlContext = new org.apache.spark.sql.SQLContext(sc)
val path = "/home/shaza90/Desktop/tweets_1428981780000"
val tweet = sqlContext.jsonFile(path).cache()
tweet.registerTempTable("tweet")
tweet.printSchema() //This one works fine
val texts = sqlContext.sql("SELECT tweet.text FROM tweet").collect().foreach(println)
我得到的例外就是这个:
java.lang.StackOverflowError
at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:254)
at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:222)
更新
我能够执行 select * from tweet
但每当我使用列名而不是*我得到错误。
有什么建议吗?