From ebd465069df6a1a9711341d2c41996424e57f094 Mon Sep 17 00:00:00 2001 From: rmahindra123 Date: Wed, 20 Dec 2023 09:55:10 -0800 Subject: [PATCH] Fix scala typedprops conversion for schema evol --- .../main/scala/org/apache/hudi/HoodieConversionUtils.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieConversionUtils.scala b/hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieConversionUtils.scala index 23efce8298426..98f9db6060ada 100644 --- a/hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieConversionUtils.scala +++ b/hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieConversionUtils.scala @@ -48,7 +48,8 @@ object HoodieConversionUtils { } def fromProperties(props: TypedProperties): Map[String, String] = { - props.asScala.toMap + props.asScala.map { + case (k, v) => (k.toString, v.toString) + }.toMap } - }