This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 20b4438377ba4421d8c161a67ea72874b46daf72 Author: Shiyan Xu <2701446+xushi...@users.noreply.github.com> AuthorDate: Thu Aug 17 01:30:29 2023 -0500 [MINOR] Fix sql core flow test (#9461) --- .../scala/org/apache/hudi/functional/TestSparkSqlCoreFlow.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkSqlCoreFlow.scala b/hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkSqlCoreFlow.scala index daf10956b69..7510204bac4 100644 --- a/hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkSqlCoreFlow.scala +++ b/hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkSqlCoreFlow.scala @@ -19,7 +19,7 @@ package org.apache.hudi.functional -import org.apache.hudi.DataSourceReadOptions.{QUERY_TYPE_INCREMENTAL_OPT_VAL, QUERY_TYPE_READ_OPTIMIZED_OPT_VAL} +import org.apache.hudi.DataSourceReadOptions.{QUERY_TYPE_READ_OPTIMIZED_OPT_VAL, QUERY_TYPE_SNAPSHOT_OPT_VAL} import org.apache.hudi.HoodieDataSourceHelpers.{hasNewCommits, latestCommit, listCommitsSince} import org.apache.hudi.common.config.HoodieMetadataConfig import org.apache.hudi.common.fs.FSUtils @@ -185,8 +185,8 @@ class TestSparkSqlCoreFlow extends HoodieSparkSqlTestBase { def doSnapshotRead(tableName: String, isMetadataEnabledOnRead: Boolean): sql.DataFrame = { try { - spark.sql("set hoodie.datasource.query.type=\"snapshot\"") - spark.sql(s"set hoodie.metadata.enable=${String.valueOf(isMetadataEnabledOnRead)}") + spark.sql(s"set hoodie.datasource.query.type=$QUERY_TYPE_SNAPSHOT_OPT_VAL") + spark.sql(s"set hoodie.metadata.enable=$isMetadataEnabledOnRead") spark.sql(s"select * from $tableName") } finally { spark.conf.unset("hoodie.datasource.query.type")