spark streaming无法使用spark sql

import org.apache.spark.streaming._
import org.apache.spark.sql._

val spark = SparkSession.builder()
  .appName("Spark Streaming with Spark SQL")
  .master("local[2]")
  .getOrCreate()

val streamingContext = new StreamingContext(spark.sparkContext, Seconds(1))

// 创建一个DStream，代表从某个数据源接收的实时数据流
val lines = streamingContext.socketTextStream("localhost", 9999)

// 将每行数据拆分为单词
val words = lines.flatMap(_.split(" "))

// 将单词转换为元组(word, 1)
val wordCounts = words.map(word => (word, 1)).reduceByKey(_ + _)

// 将实时数据流转换为DataFrame，并创建一个临时表
wordCounts.foreachRDD { rdd =>
  val wordCountDF = rdd.toDF("word", "count")
  wordCountDF.createOrReplaceTempView("word_counts")
}

// 使用Spark SQL查询临时表
val result = spark.sql("SELECT word, count FROM word_counts WHERE count > 10")

// 打印查询结果
result.show()

streamingContext.start()
streamingContext.awaitTermination()