From 1b40443d8195d3ddeb4389da13acc8875351eacd Mon Sep 17 00:00:00 2001 From: Cheng Pan Date: Thu, 23 Sep 2021 09:31:29 +0800 Subject: [PATCH] [KYUUBI #1134] [TEST] DataLake suites should clean up withKyuubiConf instead of extraConfigs --- .../engine/spark/operation/SparkDeltaOperationSuite.scala | 4 +++- .../engine/spark/operation/SparkIcebergOperationSuite.scala | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkDeltaOperationSuite.scala b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkDeltaOperationSuite.scala index be55d6747..d85b391ca 100644 --- a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkDeltaOperationSuite.scala +++ b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkDeltaOperationSuite.scala @@ -23,12 +23,14 @@ import org.apache.kyuubi.tags.DeltaTest @DeltaTest class SparkDeltaOperationSuite extends WithSparkSQLEngine with BasicDeltaJDBCTests { + override protected def jdbcUrl: String = getJdbcUrl + override def withKyuubiConf: Map[String, String] = extraConfigs override def afterAll(): Unit = { super.afterAll() - for ((k, _) <- extraConfigs) { + for ((k, _) <- withKyuubiConf) { System.clearProperty(k) } } diff --git a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkIcebergOperationSuite.scala b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkIcebergOperationSuite.scala index 153e65129..cea2438e5 100644 --- a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkIcebergOperationSuite.scala +++ b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/operation/SparkIcebergOperationSuite.scala @@ -23,12 +23,14 @@ import org.apache.kyuubi.tags.IcebergTest @IcebergTest class SparkIcebergOperationSuite extends WithSparkSQLEngine with BasicIcebergJDBCTests { + override protected def jdbcUrl: String = getJdbcUrl + override def withKyuubiConf: Map[String, String] = extraConfigs override def afterAll(): Unit = { super.afterAll() - for ((k, _) <- extraConfigs) { + for ((k, _) <- withKyuubiConf) { System.clearProperty(k) } }