This is an automated email from the ASF dual-hosted git repository. leesf pushed a commit to branch task#69426984_upgrade_hudi_version in repository https://gitbox.apache.org/repos/asf/hudi.git
commit a5251ca156baacf32f2f68dbb4ba5552c1f48057 Author: fengze <[email protected]> AuthorDate: Thu Jul 18 11:10:49 2024 +0800 to #58153311 (cherry-pick) [HUDI-7998] fix insert overwrite hudi table with static partition when defining partition column with int type --- .../src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala index e1bae0dbf3c4..e6a26a1c0d05 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala @@ -383,7 +383,7 @@ trait ProvidesHoodieConfig extends Logging { val staticPartitionValues = partitionSpec.filter(p => p._2.isDefined).mapValues(_.get) val predicates = staticPartitionValues.map { case (k, v) => val partition = AttributeReference(k, partitionNameToType(k))() - val value = Literal(v) + val value = HoodieSqlCommonUtils.castIfNeeded(Literal.create(v), partitionNameToType(k)) EqualTo(partition, value) }.toSeq Option(fileIndex.getPartitionPaths(predicates).map(_.getPath).mkString(","))
