This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit f4d4d7fa68a7b7b3d2388b7870c2ffa83f6bb4dc Author: Ashin Gau <[email protected]> AuthorDate: Wed Jul 5 10:53:09 2023 +0800 [fix](hudi) scala can't call Properties.putAll in jdk11 (#21494) --- .../src/main/scala/org/apache/doris/hudi/BaseSplitReader.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/fe/be-java-extensions/hudi-scanner/src/main/scala/org/apache/doris/hudi/BaseSplitReader.scala b/fe/be-java-extensions/hudi-scanner/src/main/scala/org/apache/doris/hudi/BaseSplitReader.scala index 92dd663847..e2ac89fab8 100644 --- a/fe/be-java-extensions/hudi-scanner/src/main/scala/org/apache/doris/hudi/BaseSplitReader.scala +++ b/fe/be-java-extensions/hudi-scanner/src/main/scala/org/apache/doris/hudi/BaseSplitReader.scala @@ -680,7 +680,9 @@ object BaseSplitReader { private def getConfigProperties(spark: SparkSession, options: Map[String, String]) = { val sqlConf: SQLConf = spark.sessionState.conf val properties = new TypedProperties() - properties.putAll(options.filter(p => p._2 != null).asJava) + // Ambiguous reference when invoking Properties.putAll() in Java 11 + // Reference https://github.com/scala/bug/issues/10418 + options.filter(p => p._2 != null).foreach(p => properties.setProperty(p._1, p._2)) // TODO(HUDI-5361) clean up properties carry-over --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
