From 17dd6cdbdd562adf5ef5aed244f0e39b9bd0b71b Mon Sep 17 00:00:00 2001 From: ulysses-you Date: Fri, 9 Aug 2024 17:57:48 +0800 Subject: [PATCH] fix --- .../sql/DisableUnnecessaryPaimonBucketedScanSuite.scala | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/DisableUnnecessaryPaimonBucketedScanSuite.scala b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/DisableUnnecessaryPaimonBucketedScanSuite.scala index 3112cdf22c094..70339bd7cac3e 100644 --- a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/DisableUnnecessaryPaimonBucketedScanSuite.scala +++ b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/DisableUnnecessaryPaimonBucketedScanSuite.scala @@ -24,7 +24,6 @@ import org.apache.paimon.spark.execution.adaptive.DisableUnnecessaryPaimonBucket import org.apache.spark.SparkConf import org.apache.spark.sql.DataFrame import org.apache.spark.sql.execution.adaptive.AdaptiveSparkPlanHelper -import org.apache.spark.sql.internal.SQLConf class DisableUnnecessaryPaimonBucketedScanSuite extends PaimonSparkTestBase @@ -49,13 +48,13 @@ class DisableUnnecessaryPaimonBucketedScanSuite assert(bucketedScan.length == expectedNumBucketedScan, query) } - withSQLConf(SQLConf.V2_BUCKETING_ENABLED.key -> "true") { - withSQLConf(SQLConf.AUTO_BUCKETED_SCAN_ENABLED.key -> "true") { + withSQLConf("spark.sql.sources.v2.bucketing.enabled" -> "true") { + withSQLConf("spark.sql.sources.bucketing.autoBucketedScan.enabled" -> "true") { val df = sql(query) val result = df.collect() checkNumBucketedScan(df, expectedNumScanWithAutoScanEnabled) - withSQLConf(SQLConf.AUTO_BUCKETED_SCAN_ENABLED.key -> "false") { + withSQLConf("spark.sql.sources.bucketing.autoBucketedScan.enabled" -> "false") { val expected = sql(query) checkAnswer(expected, result) checkNumBucketedScan(expected, expectedNumScanWithAutoScanDisabled)