我正在尝试为spark shell中的spark对象启用配置单元支持,但它不起作用。我用的是hortonworks hdp。以下是我尝试启用配置单元支持时得到的结果:
scala> val spark3 = SparkSession.builder.enableHiveSupport.getOrCreate
17/10/24 21:30:28 WARN SparkSession$Builder: Using an existing SparkSession; some configuration may not take effect.
spark3: org.apache.spark.sql.SparkSession = org.apache.spark.sql.SparkSession@22f8be7c
scala> spark3.catalog
res3: org.apache.spark.sql.catalog.Catalog = org.apache.spark.sql.internal.CatalogImpl@49c13ecd
1条答案
按热度按时间1mrurvl11#
在hdp中,
spark-shell
已使用配置单元支持创建有效的sparksession。你说得对
getOrCreate
已使用现有会话你可以试试
而且,你用的是
spark
而不是spark3
,所以不清楚是什么spark.catalog
除了那个对象的tostring信息之外,还打算给你看别的