We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 04d8e3a commit 9dc80ceCopy full SHA for 9dc80ce
sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala
@@ -49,9 +49,10 @@ private[sql] object SQLUtils extends Logging {
49
sparkConfigMap: JMap[Object, Object],
50
enableHiveSupport: Boolean): SparkSession = {
51
val spark =
52
- if (SparkSession.hiveClassesArePresent && enableHiveSupport &&
+ if (enableHiveSupport &&
53
jsc.sc.conf.get(CATALOG_IMPLEMENTATION.key, "hive").toLowerCase(Locale.ROOT) ==
54
- "hive") {
+ "hive" &&
55
+ SparkSession.hiveClassesArePresent) {
56
SparkSession.builder().sparkContext(withHiveExternalCatalog(jsc.sc)).getOrCreate()
57
} else {
58
if (enableHiveSupport) {
0 commit comments