Skip to content

Commit bf84fad

Browse files
committed
Use the loaded Comet extension too
Signed-off-by: Martin Tzvetanov Grigorov <mgrigorov@apache.org>
1 parent 9b773f3 commit bf84fad

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

dev/diffs/3.5.8.diff

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ index 27ae10b3d59..78e69902dfd 100644
7676
val extensionConfClassNames = sparkContext.getConf.get(StaticSQLConf.SPARK_SESSION_EXTENSIONS)
7777
.getOrElse(Seq.empty)
7878
+ val extensionClassNames = extensionConfClassNames ++ loadCometExtension(sparkContext)
79-
extensionConfClassNames.foreach { extensionConfClassName =>
79+
extensionClassNames.foreach { extensionConfClassName =>
8080
try {
8181
val extensionConfClass = Utils.classForName(extensionConfClassName)
8282
@@ -1396,4 +1405,12 @@ object SparkSession extends Logging {

0 commit comments

Comments
 (0)