This is an automated email from the ASF dual-hosted git repository.
chengpan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kyuubi.git
The following commit(s) were added to refs/heads/master by this push:
new 97f798768 [KYUUBI #5991] Error on reading Atlas properties composed of
multi values
97f798768 is described below
commit 97f7987689c5567217934e9bfb2605de01d4c2ea
Author: swordy_zhao <[email protected]>
AuthorDate: Tue Feb 6 22:00:53 2024 +0800
[KYUUBI #5991] Error on reading Atlas properties composed of multi values
# :mag: Description
## Issue References ๐
This pull request fixes #
## Describe Your Solution ๐ง
Please include a summary of the change and which issue is fixed. Please
also include relevant motivation and context. List any dependencies that are
required for this change.
## Types of changes :bookmark:
- [x] Bugfix (non-breaking change which fixes an issue)
- [ ] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing
functionality to change)
## Test Plan ๐งช
#### Behavior Without This Pull Request :coffin:
#### Behavior With This Pull Request :tada:
#### Related Unit Tests
---
# Checklist ๐
- [ ] This patch was not authored or co-authored using [Generative
Tooling](https://www.apache.org/legal/generative-tooling.html)
**Be nice. Be informative.**
Closes #5993 from SwordyZhao/fix-issues-5991.
Closes #5991
827007d06 [swordy_zhao] run dev/reformat fix code style.
600363dd9 [swordy_zhao] delete scala.List,Convert a java.List to scala.List
7b000e94a [swordy_zhao] fix 5991--kyuubi failed to read atlas.rest.address
5de05764e [swordy_zhao] fix 5991--kyuubi failed to read atlas.rest.address
Authored-by: swordy_zhao <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
---
.../kyuubi/plugin/lineage/dispatcher/atlas/AtlasClientConf.scala | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/extensions/spark/kyuubi-spark-lineage/src/main/scala/org/apache/kyuubi/plugin/lineage/dispatcher/atlas/AtlasClientConf.scala
b/extensions/spark/kyuubi-spark-lineage/src/main/scala/org/apache/kyuubi/plugin/lineage/dispatcher/atlas/AtlasClientConf.scala
index 03b1a83e0..65063fbeb 100644
---
a/extensions/spark/kyuubi-spark-lineage/src/main/scala/org/apache/kyuubi/plugin/lineage/dispatcher/atlas/AtlasClientConf.scala
+++
b/extensions/spark/kyuubi-spark-lineage/src/main/scala/org/apache/kyuubi/plugin/lineage/dispatcher/atlas/AtlasClientConf.scala
@@ -17,6 +17,10 @@
package org.apache.kyuubi.plugin.lineage.dispatcher.atlas
+import java.util
+
+import scala.collection.JavaConverters._
+
import org.apache.atlas.ApplicationProperties
import org.apache.commons.configuration.Configuration
import org.apache.spark.kyuubi.lineage.SparkContextHelper
@@ -26,7 +30,7 @@ class AtlasClientConf(configuration: Configuration) {
def get(entry: ConfigEntry): String = {
configuration.getProperty(entry.key) match {
case s: String => s
- case l: List[_] => l.mkString(",")
+ case jl: util.List[_] => jl.asScala.mkString(",")
case o if o != null => o.toString
case _ => entry.defaultValue
}