From cd286ec1bed70f911e34b348ebb81fda7c536216 Mon Sep 17 00:00:00 2001 From: yangjie01 Date: Mon, 4 Dec 2023 15:58:39 +0800 Subject: [PATCH 1/2] init --- .../org/apache/spark/sql/hive/execution/HiveDDLSuite.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala index c3a528da382a..1061afd3353a 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala @@ -3270,7 +3270,10 @@ class HiveDDLSuite val jarName = "TestUDTF.jar" val jar = spark.asInstanceOf[TestHiveSparkSession].getHiveFile(jarName).toURI.toString spark.sparkContext.allAddedJars.keys.find(_.contains(jarName)) - .foreach(spark.sparkContext.addedJars("default").remove) + .foreach(k => spark.sparkContext.addedJars.get("default") match { + case Some(m) => m.remove(k) + case _ => // do nothing + }) assert(!spark.sparkContext.listJars().exists(_.contains(jarName))) val e = intercept[AnalysisException] { sql("CREATE TEMPORARY FUNCTION f1 AS " + From 47e164e14178105a5d126fc31cc79f90903bf021 Mon Sep 17 00:00:00 2001 From: yangjie01 Date: Mon, 4 Dec 2023 18:52:04 +0800 Subject: [PATCH 2/2] address comments --- .../org/apache/spark/sql/hive/execution/HiveDDLSuite.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala index 1061afd3353a..2f5d1fcbb540 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveDDLSuite.scala @@ -3270,10 +3270,7 @@ class HiveDDLSuite val jarName = "TestUDTF.jar" val jar = spark.asInstanceOf[TestHiveSparkSession].getHiveFile(jarName).toURI.toString spark.sparkContext.allAddedJars.keys.find(_.contains(jarName)) - .foreach(k => spark.sparkContext.addedJars.get("default") match { - case Some(m) => m.remove(k) - case _ => // do nothing - }) + .foreach(k => spark.sparkContext.addedJars.get("default").foreach(_.remove(k))) assert(!spark.sparkContext.listJars().exists(_.contains(jarName))) val e = intercept[AnalysisException] { sql("CREATE TEMPORARY FUNCTION f1 AS " +