Skip to content

Commit 89a8752

Browse files
committed
update the if condition
1 parent 68b5823 commit 89a8752

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,7 @@ private[sql] object SQLUtils extends Logging {
5151
&& jsc.sc.conf.get(CATALOG_IMPLEMENTATION.key, "hive").toLowerCase == "hive") {
5252
SparkSession.builder().sparkContext(withHiveExternalCatalog(jsc.sc)).getOrCreate()
5353
} else {
54-
if (enableHiveSupport
55-
&& jsc.sc.conf.get(CATALOG_IMPLEMENTATION.key, "hive").toLowerCase == "hive") {
54+
if (enableHiveSupport) {
5655
logWarning("SparkR: enableHiveSupport is requested for SparkSession but " +
5756
s"Spark is not built with Hive or ${CATALOG_IMPLEMENTATION.key} is not set to 'hive', " +
5857
"falling back to without Hive support.")

0 commit comments

Comments
 (0)