Использование sparkSession в отчете набора данных NullPointException

Question

Когда я перебираю набор данных, я хочу иметь возможность использовать sparkSession для запуска некоторого sql, но он сообщает о проблеме

val session = SparkSession
  .builder()
  .master("local")
  .appName("Spark Hive Example")
  .config("spark.sql.warehouse.dir", warehouseLocation)
  .enableHiveSupport()
  .getOrCreate()

import session.implicits._

session.sql("use test")
val dataFrame = session.sql("select * from t1")
dataFrame.map(row=>{
  // session.sql("select * from tab2").show()
  //how can i run it here?
  // it report a NullPointException
}).show()

, кто может мне помочь, спасибо!