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 } - }