From 9ce548edb1b534029fa0f0617dadc3d54cdb8999 Mon Sep 17 00:00:00 2001 From: pengzhiwei Date: Fri, 6 Aug 2021 16:18:19 +0800 Subject: [PATCH] [MINOR] fix compile error in compaction command (#3421) --- .../spark/sql/hudi/command/CompactionHoodiePathCommand.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodiePathCommand.scala b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodiePathCommand.scala index c8c772ab1..e310da673 100644 --- a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodiePathCommand.scala +++ b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodiePathCommand.scala @@ -52,7 +52,7 @@ case class CompactionHoodiePathCommand(path: String, val parameters = HoodieWriterUtils.parametersWithWriteDefaults( HoodieSqlUtils.withSparkConf(sparkSession, Map.empty)( Map( - DataSourceWriteOptions.TABLE_TYPE_OPT_KEY.key() -> HoodieTableType.MERGE_ON_READ.name() + DataSourceWriteOptions.TABLE_TYPE.key() -> HoodieTableType.MERGE_ON_READ.name() ) ) )