From 3a70f75acbc9e87a8a8f86da1579748ca568c379 Mon Sep 17 00:00:00 2001 From: Scott Sandre Date: Tue, 30 Apr 2024 14:19:51 -0700 Subject: [PATCH] done --- spark/src/main/scala/org/apache/spark/sql/delta/DeltaLog.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/DeltaLog.scala b/spark/src/main/scala/org/apache/spark/sql/delta/DeltaLog.scala index c6f80d76ffd..63c7534d6a0 100644 --- a/spark/src/main/scala/org/apache/spark/sql/delta/DeltaLog.scala +++ b/spark/src/main/scala/org/apache/spark/sql/delta/DeltaLog.scala @@ -608,8 +608,7 @@ class DeltaLog private( */ protected def checkRequiredConfigurations(): Unit = { if (spark.sessionState.conf.getConf(DeltaSQLConf.DELTA_REQUIRED_SPARK_CONFS_CHECK)) { - if (spark.conf.getOption( - SQLConf.V2_SESSION_CATALOG_IMPLEMENTATION.key).isEmpty) { + if (!spark.conf.contains(SQLConf.V2_SESSION_CATALOG_IMPLEMENTATION.key)) { throw DeltaErrors.configureSparkSessionWithExtensionAndCatalog(None) } }